diff --git a/src/index.ts b/src/index.ts index 63f1269..78c269d 100644 --- a/src/index.ts +++ b/src/index.ts @@ -1,2 +1,35 @@ +import { NestFactory } from '@nestjs/core'; +import { + DataSyncModule, + DataSyncService, + EventSyncSchema, +} from './lib/data-sync'; + export * from './lib/sui-data-sync'; +const schema: EventSyncSchema = { + tableSchema: 'gifted', + transactionModule: 'simple_gift_box', + events: [ + { + eventName: 'GiftBoxMinted', + fields: { object_id: 'buffer', name: 'string', creator: 'buffer' }, + }, + ], +}; + +async function main() { + const app = await NestFactory.createMicroservice(DataSyncModule, { + logger: ['log', 'verbose', 'error', 'warn', 'debug', 'fatal'], + }); + const syncService = app.get(DataSyncService); + + syncService.setSchemas([schema]); + syncService.addSyncMoveEventType( + `0xceba50ec29ada96392373f340fe4eeffab45140ac66acc9459770e5a3c58abf8::simple_gift_box::GiftBoxMinted`, + ); + + syncService.startSync(); +} + +main().catch(console.error); diff --git a/src/lib/data-sync/index.ts b/src/lib/data-sync/index.ts index 2c41fbd..6ff3bd6 100644 --- a/src/lib/data-sync/index.ts +++ b/src/lib/data-sync/index.ts @@ -1,33 +1,2 @@ -import { NestFactory } from '@nestjs/core'; -import { DataSyncService, EventSyncSchema } from './data-sync.interface'; -import { DataSyncModule } from './data-sync.module'; - export * from './data-sync.interface'; export * from './data-sync.module'; - -const schema: EventSyncSchema = { - tableSchema: 'gifted', - transactionModule: 'simple_gift_box', - events: [ - { - eventName: 'GiftBoxMinted', - fields: { object_id: 'buffer', name: 'string', creator: 'buffer' }, - }, - ], -}; - -async function main() { - const app = await NestFactory.createMicroservice(DataSyncModule, { - logger: ['log', 'verbose', 'error', 'warn', 'debug', 'fatal'], - }); - const syncService = app.get(DataSyncService); - - syncService.setSchemas([schema]); - syncService.addSyncMoveEventType( - `0xceba50ec29ada96392373f340fe4eeffab45140ac66acc9459770e5a3c58abf8::simple_gift_box::GiftBoxMinted`, - ); - - syncService.startSync(); -} - -main().catch(console.error);