Skip to content
Snippets Groups Projects
Commit aad1dc2d authored by Felix Riehm's avatar Felix Riehm
Browse files

remove log messages, adjust pop up position, adjust buffer grouping when world map is active

parent 0b3d4ebf
No related branches found
No related tags found
No related merge requests found
...@@ -10,7 +10,6 @@ import ( ...@@ -10,7 +10,6 @@ import (
"api/websocket" "api/websocket"
"api/world_map" "api/world_map"
"encoding/json" "encoding/json"
"fmt"
"time" "time"
) )
...@@ -163,14 +162,7 @@ func (sc *Service) processEvent() { ...@@ -163,14 +162,7 @@ func (sc *Service) processEvent() {
// create websocket data for blocks // create websocket data for blocks
log.Debug("create websocket data for bloxberg.", log.Bloxberg, log.Service) log.Debug("create websocket data for bloxberg.", log.Bloxberg, log.Service)
var websocketEventData websocket.BloxbergData var websocketEventData websocket.BloxbergData
log.Debug(fmt.Sprintf("Inside processing: Location map:"), log.WorldMap)
for k, v := range sc.WorldMapData {
log.Debug(fmt.Sprintf("Location map: id: %s, lat: %f,%f", k, v.Coordinate.Lat, v.Coordinate.Long), log.WorldMap)
}
for _, block := range blocks { for _, block := range blocks {
log.Debug(fmt.Sprintf("Block: Miner hash: %s, Location: %f,%f, Location-map-size: %d",
block.MinerHash, sc.WorldMapData[block.MinerHash].Coordinate.Lat, sc.WorldMapData[block.MinerHash].Coordinate.Long,
len(sc.WorldMapData)), log.Bloxberg, log.Service)
websocketEventData.Blocks = append(websocketEventData.Blocks, websocket.BloxbergBlock{ websocketEventData.Blocks = append(websocketEventData.Blocks, websocket.BloxbergBlock{
ByteSize: block.ByteSize, ByteSize: block.ByteSize,
InsertedAt: block.InsertedAt, InsertedAt: block.InsertedAt,
...@@ -182,13 +174,6 @@ func (sc *Service) processEvent() { ...@@ -182,13 +174,6 @@ func (sc *Service) processEvent() {
// create websocket data for ConfirmedTransaction // create websocket data for ConfirmedTransaction
for _, confirmedTransaction := range confirmedTransacttions { for _, confirmedTransaction := range confirmedTransacttions {
log.Debug(fmt.Sprintf("Confirmed transaction: Miner hash: %s, Location: %f,%f, Location-map-size: %d",
confirmedTransaction.BlockMinerHash, sc.WorldMapData[confirmedTransaction.BlockMinerHash].Coordinate.Lat,
sc.WorldMapData[confirmedTransaction.BlockMinerHash].Coordinate.Long, len(sc.WorldMapData)), log.Bloxberg, log.Service)
var test = sc.WorldMapData[confirmedTransaction.BlockMinerHash]
log.Debug(fmt.Sprintf("Test: Miner hash: %s, Location: %f,%f, Location-map-size: %d",
confirmedTransaction.BlockMinerHash, test.Coordinate.Lat,
test.Coordinate.Long, len(sc.WorldMapData)), log.Bloxberg, log.Service)
websocketEventData.ConfirmedTransactions = append(websocketEventData.ConfirmedTransactions, websocket.BloxbergConfirmedTransaction{ websocketEventData.ConfirmedTransactions = append(websocketEventData.ConfirmedTransactions, websocket.BloxbergConfirmedTransaction{
TransactionFee: confirmedTransaction.TransactionFee, TransactionFee: confirmedTransaction.TransactionFee,
UpdatedAt: confirmedTransaction.UpdatedAt, UpdatedAt: confirmedTransaction.UpdatedAt,
...@@ -244,9 +229,5 @@ func (sc *Service) loadWorldMapData() { ...@@ -244,9 +229,5 @@ func (sc *Service) loadWorldMapData() {
mail.SendErrorMail(logMessage, worldMapErr) mail.SendErrorMail(logMessage, worldMapErr)
} else { } else {
sc.WorldMapData = worldMapData sc.WorldMapData = worldMapData
log.Debug(fmt.Sprintf("Inside load: Location map:"), log.WorldMap)
for k, v := range sc.WorldMapData {
log.Debug(fmt.Sprintf("Location map: id: %s, lat: %f,%f", k, v.Coordinate.Lat, v.Coordinate.Long), log.WorldMap)
}
} }
} }
...@@ -13,10 +13,10 @@ var ( ...@@ -13,10 +13,10 @@ var (
infoLogger *log.Logger infoLogger *log.Logger
debugLogger *log.Logger debugLogger *log.Logger
traceLogger *log.Logger traceLogger *log.Logger
logLevel int LogLevel int
) )
func Init(LogAbsolutePath string, LogMaxSize int, LogMaxBackups int, LogMaxAge int, LogCompress bool, LogLevel int, func Init(LogAbsolutePath string, LogMaxSize int, LogMaxBackups int, LogMaxAge int, LogCompress bool, LogLevelParameter int,
appEnvironment string) { appEnvironment string) {
// Set up logging // Set up logging
output := &lumberjack.Logger{ output := &lumberjack.Logger{
...@@ -26,7 +26,7 @@ func Init(LogAbsolutePath string, LogMaxSize int, LogMaxBackups int, LogMaxAge i ...@@ -26,7 +26,7 @@ func Init(LogAbsolutePath string, LogMaxSize int, LogMaxBackups int, LogMaxAge i
MaxAge: LogMaxAge, // days MaxAge: LogMaxAge, // days
Compress: LogCompress, // compress backed up log files Compress: LogCompress, // compress backed up log files
} }
logLevel = LogLevel LogLevel = LogLevelParameter
fatalLogger = log.New(output, appEnvironment+" [FATAL] ", log.Ldate|log.Ltime) fatalLogger = log.New(output, appEnvironment+" [FATAL] ", log.Ldate|log.Ltime)
errorLogger = log.New(output, appEnvironment+" [ERROR] ", log.Ldate|log.Ltime) errorLogger = log.New(output, appEnvironment+" [ERROR] ", log.Ldate|log.Ltime)
...@@ -37,37 +37,37 @@ func Init(LogAbsolutePath string, LogMaxSize int, LogMaxBackups int, LogMaxAge i ...@@ -37,37 +37,37 @@ func Init(LogAbsolutePath string, LogMaxSize int, LogMaxBackups int, LogMaxAge i
} }
func Fatal(msg string, err error, concerns ...Concern) { func Fatal(msg string, err error, concerns ...Concern) {
if logLevel >= 1 { if LogLevel >= 1 {
fatalLogger.Fatalln(concernsToString(concerns...), msgToString(msg, err)) fatalLogger.Fatalln(concernsToString(concerns...), msgToString(msg, err))
} }
} }
func Error(msg string, err error, concerns ...Concern) { func Error(msg string, err error, concerns ...Concern) {
if logLevel >= 2 { if LogLevel >= 2 {
errorLogger.Println(concernsToString(concerns...), msgToString(msg, err)) errorLogger.Println(concernsToString(concerns...), msgToString(msg, err))
} }
} }
func Warn(msg string, concerns ...Concern) { func Warn(msg string, concerns ...Concern) {
if logLevel >= 3 { if LogLevel >= 3 {
warningLogger.Println(concernsToString(concerns...), msgToString(msg, nil)) warningLogger.Println(concernsToString(concerns...), msgToString(msg, nil))
} }
} }
func Info(msg string, concerns ...Concern) { func Info(msg string, concerns ...Concern) {
if logLevel >= 4 { if LogLevel >= 4 {
infoLogger.Println(concernsToString(concerns...), msgToString(msg, nil)) infoLogger.Println(concernsToString(concerns...), msgToString(msg, nil))
} }
} }
func Debug(msg string, concerns ...Concern) { func Debug(msg string, concerns ...Concern) {
if logLevel >= 5 { if LogLevel >= 5 {
debugLogger.Println(concernsToString(concerns...), msgToString(msg, nil)) debugLogger.Println(concernsToString(concerns...), msgToString(msg, nil))
} }
} }
func Trace(msg string, concerns ...Concern) { func Trace(msg string, concerns ...Concern) {
if logLevel >= 6 { if LogLevel >= 6 {
traceLogger.Println(concernsToString(concerns...), msgToString(msg, nil)) traceLogger.Println(concernsToString(concerns...), msgToString(msg, nil))
} }
} }
......
...@@ -46,9 +46,11 @@ func (idc *Controller) Load() (worldMapDataMap map[string]Location, e error) { ...@@ -46,9 +46,11 @@ func (idc *Controller) Load() (worldMapDataMap map[string]Location, e error) {
} }
} }
log.Debug(fmt.Sprintf("Location map:"), log.WorldMap) if log.LogLevel >= 5 {
for k, v := range worldMapDataMap { log.Debug(fmt.Sprintf("Location map:"), log.WorldMap)
log.Debug(fmt.Sprintf("Location map: id: %s, lat: %f,%f", k, v.Coordinate.Lat, v.Coordinate.Long), log.WorldMap) for k, v := range worldMapDataMap {
log.Debug(fmt.Sprintf("id: %s, lat,long: %f,%f", k, v.Coordinate.Lat, v.Coordinate.Long), log.WorldMap)
}
} }
return return
......
...@@ -56,7 +56,7 @@ export class Circle{ ...@@ -56,7 +56,7 @@ export class Circle{
const popUpContainer = this.circlesLayer.canvas.appContainer.append("div"); const popUpContainer = this.circlesLayer.canvas.appContainer.append("div");
popUpContainer popUpContainer
.style('position', 'absolute') .style('position', 'absolute')
.style('top', `${y + 10}px`) .style('top', `${y - this.circlesLayer.canvas.theme.header_height + 10}px`)
.style('left', `${x + 10}px`) .style('left', `${x + 10}px`)
.style('padding', '4px') .style('padding', '4px')
.style('border-radius', '1px') .style('border-radius', '1px')
......
...@@ -4,11 +4,13 @@ import {getRandomIntInclusive} from "../util/random"; ...@@ -4,11 +4,13 @@ import {getRandomIntInclusive} from "../util/random";
export class EventBuffer { export class EventBuffer {
private readonly eventBuffer: Map<ServiceEvent, EventBufferData>; private readonly eventBuffer: Map<ServiceEvent, EventBufferData>;
private readonly hatnote_map: boolean;
constructor(default_event_buffer_timespan: number, publishCircleEvent: (circleEvent: DelayedCircleEvent[]) => void, hatnote_map: boolean) { constructor(default_event_buffer_timespan: number, publishCircleEvent: (circleEvent: DelayedCircleEvent[]) => void, hatnote_map: boolean) {
this.hatnote_map = hatnote_map;
this.eventBuffer = new Map([ this.eventBuffer = new Map([
[ServiceEvent.bloxberg_block, new EventBufferData(publishCircleEvent, hatnote_map, default_event_buffer_timespan)], [ServiceEvent.bloxberg_block, new EventBufferData(publishCircleEvent, hatnote_map, default_event_buffer_timespan)],
[ServiceEvent.bloxberg_confirmed_transaction, new EventBufferData(publishCircleEvent, hatnote_map, default_event_buffer_timespan, 1200)], [ServiceEvent.bloxberg_confirmed_transaction, new EventBufferData(publishCircleEvent, hatnote_map, default_event_buffer_timespan, hatnote_map ? 1000 : 1200)],
[ServiceEvent.keeper_file_create, new EventBufferData(publishCircleEvent, hatnote_map, 1000,1000)], // Keeper only returns time precision of seconds [ServiceEvent.keeper_file_create, new EventBufferData(publishCircleEvent, hatnote_map, 1000,1000)], // Keeper only returns time precision of seconds
[ServiceEvent.keeper_file_edit, new EventBufferData(publishCircleEvent, hatnote_map, 1000,1000)], // Keeper only returns time precision of seconds [ServiceEvent.keeper_file_edit, new EventBufferData(publishCircleEvent, hatnote_map, 1000,1000)], // Keeper only returns time precision of seconds
[ServiceEvent.keeper_new_library, new EventBufferData(publishCircleEvent, hatnote_map, 1000,1000)], // Keeper only returns time precision of seconds [ServiceEvent.keeper_new_library, new EventBufferData(publishCircleEvent, hatnote_map, 1000,1000)], // Keeper only returns time precision of seconds
...@@ -30,6 +32,7 @@ export class EventBuffer { ...@@ -30,6 +32,7 @@ export class EventBuffer {
return return
if(eventBufferData.isEventCirclesArrayEmpty()){ if(eventBufferData.isEventCirclesArrayEmpty()){
let that = this;
setTimeout(function(){ setTimeout(function(){
switch (circleEvent) { switch (circleEvent) {
case ServiceEvent.keeper_file_create: case ServiceEvent.keeper_file_create:
...@@ -38,8 +41,10 @@ export class EventBuffer { ...@@ -38,8 +41,10 @@ export class EventBuffer {
eventBufferData?.splitBufferAndRelease(splitRandom) eventBufferData?.splitBufferAndRelease(splitRandom)
break; break;
case ServiceEvent.bloxberg_confirmed_transaction: case ServiceEvent.bloxberg_confirmed_transaction:
let splitRandomBloxberg = 3 if (!that.hatnote_map) {
eventBufferData?.splitBufferAndRelease(splitRandomBloxberg) let splitRandomBloxberg = 3
eventBufferData?.splitBufferAndRelease(splitRandomBloxberg)
}
break; break;
default: default:
eventBufferData?.releaseBuffer() eventBufferData?.releaseBuffer()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment