small log enhancements

CHANGELOG.md

@@ -1,3 +1,9 @@
+# v0.4.2 (unreleased)
+
+- fix: fixed a bug with the indexing logic
+- chore: slight adustment to the console logger
+- feat: added a log to indicate when the arkiver starts indexing live
+
 # v0.4.1
 
 - feat: change `arkiver remove` command to use the arkive name specified in the

cli/start/mod.ts

@@ -66,11 +66,17 @@ export const action = async (
 
 	log.setup({
 		handlers: {
-			console: new ArkiveConsoleLogHandler(options.logLevel as log.LevelName, {
-				arkiveName: manifest.name ?? 'my-arkive',
-				arkiveId: 0,
-				arkiveVersion: 1,
-			}),
+			console: new ArkiveConsoleLogHandler(
+				options.logLevel.toUpperCase() as log.LevelName,
+				{
+					arkive: {
+						name: manifest.name ?? 'my-arkive',
+						id: 0,
+						majorVersion: 1,
+						minorVersion: 0,
+					},
+				},
+			),
 		},
 		loggers: {
 			arkiver: {

src/arkiver/data-source.ts

@@ -183,7 +183,12 @@ export class DataSource {
 				this.liveBlockHeight,
 			)
 
-			if (toBlock === this.liveBlockHeight && !this.isLive) this.isLive = true
+			if (toBlock === this.liveBlockHeight && !this.isLive) {
+				this.isLive = true
+				logger().info(
+					`Start live arkiving for ${this.chain} at ${this.liveBlockHeight}`,
+				)
+			}
 
 			if (fromBlock > toBlock) {
 				await delay(this.liveDelay)
@@ -359,9 +364,6 @@ export class DataSource {
 			(source.startBlockHeight === 'live' && this.isLive)
 		)
 		if (blockSources.length === 0) {
-			logger().debug(
-				`No filtered block sources found for ${this.chain} at ${this.fetchedBlockHeight}`,
-			)
 			this.blocksQueue.set(
 				fromBlock,
 				{

src/logger.ts

@@ -1,35 +1,36 @@
-import { colors, ConsoleHandler, log } from "./deps.ts";
+import { colors, ConsoleHandler, log } from './deps.ts'
+
+type Arkive = {
+	name: string
+	majorVersion: number
+	minorVersion: number
+	id: number
+}
 
 export class ArkiveConsoleLogHandler extends ConsoleHandler {
-  private arkiveName: string;
-  private arkiveId: number;
-  private arkiveVersion: number;
+	private arkive: Arkive
 
-  constructor(
-    levelName: log.LevelName,
-    options: log.HandlerOptions & {
-      arkiveName: string;
-      arkiveId: number;
-      arkiveVersion: number;
-    },
-  ) {
-    super(levelName, options);
-    this.arkiveName = options.arkiveName;
-    this.arkiveId = options.arkiveId;
-    this.arkiveVersion = options.arkiveVersion;
-  }
+	constructor(
+		levelName: log.LevelName,
+		options: log.HandlerOptions & {
+			arkive: Arkive
+		},
+	) {
+		super(levelName, options)
+		this.arkive = options.arkive
+	}
 
-  override format(logRecord: log.LogRecord): string {
-    let msg = super.format(logRecord);
+	override format(logRecord: log.LogRecord): string {
+		let msg = super.format(logRecord)
 
-    msg = `${
-      colors.blue(
-        `[${this.arkiveId}-${this.arkiveName}@v${this.arkiveVersion}]`,
-      )
-    } ${msg}`;
+		msg = `${
+			colors.blue(
+				`[${this.arkive.id}:${this.arkive.name}@v${this.arkive.majorVersion}.${this.arkive.minorVersion}]`,
+			)
+		} ${msg}`
 
-    return msg;
-  }
+		return msg
+	}
 }
 
-export const logger = () => log.getLogger("arkiver");
+export const logger = () => log.getLogger('arkiver')