# coding: utf8 # toutes les chaines sont en unicode (même les docstrings) from __future__ import unicode_literals # from pprint import pprint from rocketchat_API.rocketchat import RocketChat import json import os import random from datetime import datetime from monthdelta import monthdelta from common.rocketchathelper import getAllChannels, getAllMessages, Connection from common.savehelper import save from common.charthelper import createElement, getColor, setTsunamyInfo, Tsunami, getTsunamy begin = datetime.now() end = datetime.now() def main(): global begin, end rocket = Connection() labels = [None] * 12 messagesByChannel = [] usersByChannel = [] messagesDataTsunamy = { Tsunami.GLOBAL: [0] * 12, Tsunami.PROJECT: [0] * 12, Tsunami.DEMOCRACY: [0] * 12, Tsunami.ECOLOGY: [0] * 12, Tsunami.TECHNOLOGY: [0] * 12, } usersGlobal = [] now = datetime.now() date = datetime(now.year, now.month, now.day, 0,0,0) info = { "updated": "updated {:02}/{:02}/{:04}".format(now.day, now.month, now.year), "labels": labels, "messagesByChannel": messagesByChannel, "usersByChannel": usersByChannel, "messagesByTsunamy": [ createElement("global", getColor(), messagesDataTsunamy[Tsunami.GLOBAL]), createElement("project", getColor(), messagesDataTsunamy[Tsunami.PROJECT]), createElement("democratie", getColor(), messagesDataTsunamy[Tsunami.DEMOCRACY]), createElement("ecologie", getColor(), messagesDataTsunamy[Tsunami.ECOLOGY]), createElement("technologie", getColor(), messagesDataTsunamy[Tsunami.TECHNOLOGY]) ], "usersGlobal": usersGlobal } uniqueUserGlobal = [None] * 12 for channel in getAllChannels(rocket): dataMess = [] dataUsers = [] print( channel['name'] ) begin = date - monthdelta(12) end = begin + monthdelta(1) messages = getAllMessages(rocket, channel['_id'], begindate= begin, enddate=date, count= channel['msgs']) tsunamy = getTsunamy(channel) for id in range(0, 12): if uniqueUserGlobal[id] == None: uniqueUserGlobal[id] = [] labels[id] = begin.strftime("%b %Y") print(f"\t{labels[id]}") resultMess = list(filter(lambda mess: begin < datetime.strptime(mess["ts"], "%Y-%m-%dT%H:%M:%S.%fZ") < end, messages)) length = len(resultMess) dataMess.append(length) if length > 0: setTsunamyInfo(tsunamy, messagesDataTsunamy, id, length) users = [] for mess in resultMess: users.append(mess['u']['_id']) uniqueUserGlobal[id].append(mess['u']['_id']) usersDistinct = set(users) dataUsers.append(len(usersDistinct)) else: dataUsers.append(0) begin = end end = begin + monthdelta(1) color = getColor() messageByChannel = createElement(channel['name'], color,dataMess) userByChannel = createElement( channel['name'], color,dataUsers) messagesByChannel.append(messageByChannel) usersByChannel.append(userByChannel) for id in range(0, 12): uniqueUserGlobal[id] = len(set(uniqueUserGlobal[id])) userGlobal = createElement( 'global', 'red', uniqueUserGlobal) usersGlobal.append(userGlobal) save(info, "chat_stat_monthly") if __name__ == "__main__": main()