{"version":3,"sources":["../../src/stream/index.ts","../../src/stream/entity/Stream.ts","../../src/stream/entity/StreamEvent.ts","../../src/common/config.ts","../../src/stream/entity/StreamProcessor.ts","../../src/common/BaseModel.ts","../../src/stream/StreamModel.ts"],"sourcesContent":["import 'reflect-metadata';\n\nexport { Stream } from './entity/Stream';\nexport { StreamEvent } from './entity/StreamEvent';\nexport { StreamProcessor } from './entity/StreamProcessor';\nexport { StreamModel } from './StreamModel';\n","var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) {\n    var c = arguments.length, r = c < 3 ? target : desc === null ? desc = Object.getOwnPropertyDescriptor(target, key) : desc, d;\n    if (typeof Reflect === \"object\" && typeof Reflect.decorate === \"function\") r = Reflect.decorate(decorators, target, key, desc);\n    else for (var i = decorators.length - 1; i >= 0; i--) if (d = decorators[i]) r = (c < 3 ? d(r) : c > 3 ? d(target, key, r) : d(target, key)) || r;\n    return c > 3 && r && Object.defineProperty(target, key, r), r;\n};\nvar __metadata = (this && this.__metadata) || function (k, v) {\n    if (typeof Reflect === \"object\" && typeof Reflect.metadata === \"function\") return Reflect.metadata(k, v);\n};\nvar _a, _b, _c;\nimport { Column, CreateDateColumn, Entity, Index, PrimaryGeneratedColumn, Unique, UpdateDateColumn } from 'typeorm';\nlet Stream = class Stream {\n    id;\n    address;\n    groupId;\n    groupIndex;\n    coinType;\n    balance;\n    objectVersion;\n    creator;\n    recipient;\n    timeStart;\n    cliff;\n    epochInterval;\n    totalEpoch;\n    amountPerEpoch;\n    cancelable;\n    autoClaimEnabled;\n    rawData;\n    status;\n    updatedAt;\n    createdAt;\n};\n__decorate([\n    PrimaryGeneratedColumn(),\n    __metadata(\"design:type\", Number)\n], Stream.prototype, \"id\", void 0);\n__decorate([\n    Column(),\n    Index({ unique: true }),\n    __metadata(\"design:type\", String)\n], Stream.prototype, \"address\", void 0);\n__decorate([\n    Column(),\n    Index(),\n    __metadata(\"design:type\", String)\n], Stream.prototype, \"groupId\", void 0);\n__decorate([\n    Column(),\n    __metadata(\"design:type\", Number)\n], Stream.prototype, \"groupIndex\", void 0);\n__decorate([\n    Column(),\n    Index(),\n    __metadata(\"design:type\", String)\n], Stream.prototype, \"coinType\", void 0);\n__decorate([\n    Column('bigint'),\n    __metadata(\"design:type\", String)\n], Stream.prototype, \"balance\", void 0);\n__decorate([\n    Column('bigint'),\n    __metadata(\"design:type\", String)\n], Stream.prototype, \"objectVersion\", void 0);\n__decorate([\n    Column(),\n    Index(),\n    __metadata(\"design:type\", String)\n], Stream.prototype, \"creator\", void 0);\n__decorate([\n    Column(),\n    Index(),\n    __metadata(\"design:type\", String)\n], Stream.prototype, \"recipient\", void 0);\n__decorate([\n    Column(),\n    __metadata(\"design:type\", typeof (_a = typeof Date !== \"undefined\" && Date) === \"function\" ? _a : Object)\n], Stream.prototype, \"timeStart\", void 0);\n__decorate([\n    Column('bigint'),\n    __metadata(\"design:type\", String)\n], Stream.prototype, \"cliff\", void 0);\n__decorate([\n    Column('bigint'),\n    __metadata(\"design:type\", String)\n], Stream.prototype, \"epochInterval\", void 0);\n__decorate([\n    Column('bigint'),\n    __metadata(\"design:type\", String)\n], Stream.prototype, \"totalEpoch\", void 0);\n__decorate([\n    Column('bigint'),\n    __metadata(\"design:type\", String)\n], Stream.prototype, \"amountPerEpoch\", void 0);\n__decorate([\n    Column(),\n    __metadata(\"design:type\", Boolean)\n], Stream.prototype, \"cancelable\", void 0);\n__decorate([\n    Column(),\n    Index(),\n    __metadata(\"design:type\", Boolean)\n], Stream.prototype, \"autoClaimEnabled\", void 0);\n__decorate([\n    Column('text'),\n    __metadata(\"design:type\", String)\n], Stream.prototype, \"rawData\", void 0);\n__decorate([\n    Column(),\n    __metadata(\"design:type\", String)\n], Stream.prototype, \"status\", void 0);\n__decorate([\n    UpdateDateColumn(),\n    __metadata(\"design:type\", typeof (_b = typeof Date !== \"undefined\" && Date) === \"function\" ? _b : Object)\n], Stream.prototype, \"updatedAt\", void 0);\n__decorate([\n    CreateDateColumn(),\n    __metadata(\"design:type\", typeof (_c = typeof Date !== \"undefined\" && Date) === \"function\" ? _c : Object)\n], Stream.prototype, \"createdAt\", void 0);\nStream = __decorate([\n    Entity({ name: 'stream' }),\n    Unique(['groupId', 'groupIndex'])\n], Stream);\nexport { Stream };\n//# sourceMappingURL=module.js.map","var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) {\n    var c = arguments.length, r = c < 3 ? target : desc === null ? desc = Object.getOwnPropertyDescriptor(target, key) : desc, d;\n    if (typeof Reflect === \"object\" && typeof Reflect.decorate === \"function\") r = Reflect.decorate(decorators, target, key, desc);\n    else for (var i = decorators.length - 1; i >= 0; i--) if (d = decorators[i]) r = (c < 3 ? d(r) : c > 3 ? d(target, key, r) : d(target, key)) || r;\n    return c > 3 && r && Object.defineProperty(target, key, r), r;\n};\nvar __metadata = (this && this.__metadata) || function (k, v) {\n    if (typeof Reflect === \"object\" && typeof Reflect.metadata === \"function\") return Reflect.metadata(k, v);\n};\nvar _a, _b, _c;\nimport { Column, CreateDateColumn, Entity, Index, PrimaryGeneratedColumn, Unique, UpdateDateColumn } from 'typeorm';\nimport { getLongTextEntityType } from '@/common/config';\nlet StreamEvent = class StreamEvent {\n    id;\n    txDigest;\n    eventIndex;\n    streamAddress;\n    eventType;\n    data;\n    amount;\n    coinType;\n    sender;\n    executedAt;\n    updatedAt;\n    createdAt;\n};\n__decorate([\n    PrimaryGeneratedColumn(),\n    __metadata(\"design:type\", Number)\n], StreamEvent.prototype, \"id\", void 0);\n__decorate([\n    Column(),\n    Index(),\n    __metadata(\"design:type\", String)\n], StreamEvent.prototype, \"txDigest\", void 0);\n__decorate([\n    Column(),\n    __metadata(\"design:type\", Number)\n], StreamEvent.prototype, \"eventIndex\", void 0);\n__decorate([\n    Column(),\n    __metadata(\"design:type\", String)\n], StreamEvent.prototype, \"streamAddress\", void 0);\n__decorate([\n    Column(),\n    __metadata(\"design:type\", String)\n], StreamEvent.prototype, \"eventType\", void 0);\n__decorate([\n    Column(getLongTextEntityType()),\n    __metadata(\"design:type\", String)\n], StreamEvent.prototype, \"data\", void 0);\n__decorate([\n    Column('bigint'),\n    __metadata(\"design:type\", String)\n], StreamEvent.prototype, \"amount\", void 0);\n__decorate([\n    Column(),\n    __metadata(\"design:type\", String)\n], StreamEvent.prototype, \"coinType\", void 0);\n__decorate([\n    Column(),\n    __metadata(\"design:type\", String)\n], StreamEvent.prototype, \"sender\", void 0);\n__decorate([\n    Column(),\n    __metadata(\"design:type\", typeof (_a = typeof Date !== \"undefined\" && Date) === \"function\" ? _a : Object)\n], StreamEvent.prototype, \"executedAt\", void 0);\n__decorate([\n    UpdateDateColumn(),\n    __metadata(\"design:type\", typeof (_b = typeof Date !== \"undefined\" && Date) === \"function\" ? _b : Object)\n], StreamEvent.prototype, \"updatedAt\", void 0);\n__decorate([\n    CreateDateColumn(),\n    __metadata(\"design:type\", typeof (_c = typeof Date !== \"undefined\" && Date) === \"function\" ? _c : Object)\n], StreamEvent.prototype, \"createdAt\", void 0);\nStreamEvent = __decorate([\n    Entity({ name: 'stream_event' }),\n    Unique(['txDigest', 'eventIndex'])\n], StreamEvent);\nexport { StreamEvent };\n//# sourceMappingURL=module.js.map","import { MysqlConnectionOptions } from 'typeorm/driver/mysql/MysqlConnectionOptions';\nimport { SqliteConnectionOptions } from 'typeorm/driver/sqlite/SqliteConnectionOptions';\n\n/**\n * Config of database connection, which is an alias to MySql connection or Sqlite connection.\n * Sqlite connection is only supported in unit test environment.\n *\n * Please do not use the following parameter in the configuration:\n *  - synchronize (Unsafe)\n *  - dropSchema (Unsafe)\n *  - entities (already defined in entity package)\n */\nexport type ModelConfig = MysqlConnectionOptions | SqliteConnectionOptions;\n\nexport type ModelConfigProvider = (() => Promise<ModelConfig>) | ModelConfig;\n\n/**\n * Checks if the current environment is a unit test environment.\n * Sqlite entity type will be different in these environments.\n *\n * @return {boolean} Returns `true` if the current environment is a unit test environment, otherwise `false`.\n */\nexport function isUnitTestEnv(): boolean {\n  return typeof window === 'undefined' && process.env.NODE_ENV === 'test';\n}\n\n/**\n * Returns the type argument for a long text based on the environment.\n *\n * @return {'text' | 'longtext'} - The type argument for a long text.\n */\nexport function getLongTextEntityType(): 'text' | 'longtext' {\n  return isUnitTestEnv() ? 'text' : 'longtext';\n}\n","var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) {\n    var c = arguments.length, r = c < 3 ? target : desc === null ? desc = Object.getOwnPropertyDescriptor(target, key) : desc, d;\n    if (typeof Reflect === \"object\" && typeof Reflect.decorate === \"function\") r = Reflect.decorate(decorators, target, key, desc);\n    else for (var i = decorators.length - 1; i >= 0; i--) if (d = decorators[i]) r = (c < 3 ? d(r) : c > 3 ? d(target, key, r) : d(target, key)) || r;\n    return c > 3 && r && Object.defineProperty(target, key, r), r;\n};\nvar __metadata = (this && this.__metadata) || function (k, v) {\n    if (typeof Reflect === \"object\" && typeof Reflect.metadata === \"function\") return Reflect.metadata(k, v);\n};\nvar _a, _b;\nimport { Column, CreateDateColumn, Entity, PrimaryGeneratedColumn, UpdateDateColumn } from 'typeorm';\nlet StreamProcessor = class StreamProcessor {\n    id;\n    fieldName;\n    fieldValue;\n    updatedAt;\n    createdAt;\n};\n__decorate([\n    PrimaryGeneratedColumn(),\n    __metadata(\"design:type\", Number)\n], StreamProcessor.prototype, \"id\", void 0);\n__decorate([\n    Column({ unique: true }),\n    __metadata(\"design:type\", String)\n], StreamProcessor.prototype, \"fieldName\", void 0);\n__decorate([\n    Column(),\n    __metadata(\"design:type\", String)\n], StreamProcessor.prototype, \"fieldValue\", void 0);\n__decorate([\n    UpdateDateColumn(),\n    __metadata(\"design:type\", typeof (_a = typeof Date !== \"undefined\" && Date) === \"function\" ? _a : Object)\n], StreamProcessor.prototype, \"updatedAt\", void 0);\n__decorate([\n    CreateDateColumn(),\n    __metadata(\"design:type\", typeof (_b = typeof Date !== \"undefined\" && Date) === \"function\" ? _b : Object)\n], StreamProcessor.prototype, \"createdAt\", void 0);\nStreamProcessor = __decorate([\n    Entity({ name: 'stream_processor' })\n], StreamProcessor);\nexport { StreamProcessor };\n//# sourceMappingURL=module.js.map","import { DataSource } from 'typeorm';\n\nimport { ModelConfigProvider } from '@/common/config';\n\nexport class BaseModel {\n  dataSource: DataSource;\n\n  protected constructor(\n    private readonly configProvider: ModelConfigProvider,\n    private readonly entities: any[],\n  ) {}\n\n  protected async init() {\n    const config = typeof this.configProvider === 'function' ? await this.configProvider() : this.configProvider;\n    this.dataSource = new DataSource({\n      ...config,\n\n      // Overwrite unsafe fields\n      synchronize: false,\n      dropSchema: false,\n\n      // Override with entities defined in each module\n      entities: this.entities,\n    });\n    await this.dataSource.initialize();\n  }\n\n  async synchronize(dropBeforeSync: boolean) {\n    await this.dataSource.synchronize(dropBeforeSync);\n  }\n\n  async close() {\n    await this.dataSource.destroy();\n  }\n\n  entityManager() {\n    return this.dataSource.manager;\n  }\n}\n","import { Repository } from 'typeorm';\n\nimport { BaseModel } from '@/common/BaseModel';\nimport { ModelConfig, ModelConfigProvider } from '@/common/config';\nimport { Stream } from '@/stream/entity/Stream';\nimport { StreamEvent } from '@/stream/entity/StreamEvent';\nimport { StreamProcessor } from '@/stream/entity/StreamProcessor';\n\nexport class StreamModel extends BaseModel {\n  stream: Repository<Stream>;\n\n  streamEvent: Repository<StreamEvent>;\n\n  streamProcessor: Repository<StreamProcessor>;\n\n  protected constructor(configProvider: ModelConfigProvider) {\n    super(configProvider, [Stream, StreamEvent, StreamProcessor]);\n  }\n\n  protected async init() {\n    await super.init();\n\n    this.stream = this.dataSource.getRepository(Stream);\n    this.streamEvent = this.dataSource.getRepository(StreamEvent);\n    this.streamProcessor = this.dataSource.getRepository(StreamProcessor);\n  }\n\n  static async New(config: ModelConfig) {\n    const stream = new StreamModel(config);\n    await stream.init();\n\n    return stream;\n  }\n}\n"],"mappings":";;;;;;;;;;;;;;;;;;;;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA,8BAAO;;;ACUP,qBAA0G;AAV1G,IAAI,aAA0C,SAAU,YAAY,QAAQ,KAAK,MAAM;AACnF,MAAI,IAAI,UAAU,QAAQ,IAAI,IAAI,IAAI,SAAS,SAAS,OAAO,OAAO,OAAO,yBAAyB,QAAQ,GAAG,IAAI,MAAM;AAC3H,MAAI,OAAO,YAAY,YAAY,OAAO,QAAQ,aAAa;AAAY,QAAI,QAAQ,SAAS,YAAY,QAAQ,KAAK,IAAI;AAAA;AACxH,aAAS,IAAI,WAAW,SAAS,GAAG,KAAK,GAAG;AAAK,UAAI,IAAI,WAAW,CAAC;AAAG,aAAK,IAAI,IAAI,EAAE,CAAC,IAAI,IAAI,IAAI,EAAE,QAAQ,KAAK,CAAC,IAAI,EAAE,QAAQ,GAAG,MAAM;AAChJ,SAAO,IAAI,KAAK,KAAK,OAAO,eAAe,QAAQ,KAAK,CAAC,GAAG;AAChE;AACA,IAAI,aAA0C,SAAU,GAAG,GAAG;AAC1D,MAAI,OAAO,YAAY,YAAY,OAAO,QAAQ,aAAa;AAAY,WAAO,QAAQ,SAAS,GAAG,CAAC;AAC3G;AACA,IAAI;AAAJ,IAAQ;AAAR,IAAY;AAEZ,IAAI,SAAS,MAAMA,QAAO;AAAA,EACtB;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AACJ;AACA,WAAW;AAAA,MACP,uCAAuB;AAAA,EACvB,WAAW,eAAe,MAAM;AACpC,GAAG,OAAO,WAAW,MAAM,MAAM;AACjC,WAAW;AAAA,MACP,uBAAO;AAAA,MACP,sBAAM,EAAE,QAAQ,KAAK,CAAC;AAAA,EACtB,WAAW,eAAe,MAAM;AACpC,GAAG,OAAO,WAAW,WAAW,MAAM;AACtC,WAAW;AAAA,MACP,uBAAO;AAAA,MACP,sBAAM;AAAA,EACN,WAAW,eAAe,MAAM;AACpC,GAAG,OAAO,WAAW,WAAW,MAAM;AACtC,WAAW;AAAA,MACP,uBAAO;AAAA,EACP,WAAW,eAAe,MAAM;AACpC,GAAG,OAAO,WAAW,cAAc,MAAM;AACzC,WAAW;AAAA,MACP,uBAAO;AAAA,MACP,sBAAM;AAAA,EACN,WAAW,eAAe,MAAM;AACpC,GAAG,OAAO,WAAW,YAAY,MAAM;AACvC,WAAW;AAAA,MACP,uBAAO,QAAQ;AAAA,EACf,WAAW,eAAe,MAAM;AACpC,GAAG,OAAO,WAAW,WAAW,MAAM;AACtC,WAAW;AAAA,MACP,uBAAO,QAAQ;AAAA,EACf,WAAW,eAAe,MAAM;AACpC,GAAG,OAAO,WAAW,iBAAiB,MAAM;AAC5C,WAAW;AAAA,MACP,uBAAO;AAAA,MACP,sBAAM;AAAA,EACN,WAAW,eAAe,MAAM;AACpC,GAAG,OAAO,WAAW,WAAW,MAAM;AACtC,WAAW;AAAA,MACP,uBAAO;AAAA,MACP,sBAAM;AAAA,EACN,WAAW,eAAe,MAAM;AACpC,GAAG,OAAO,WAAW,aAAa,MAAM;AACxC,WAAW;AAAA,MACP,uBAAO;AAAA,EACP,WAAW,eAAe,QAAQ,KAAK,OAAO,SAAS,eAAe,UAAU,aAAa,KAAK,MAAM;AAC5G,GAAG,OAAO,WAAW,aAAa,MAAM;AACxC,WAAW;AAAA,MACP,uBAAO,QAAQ;AAAA,EACf,WAAW,eAAe,MAAM;AACpC,GAAG,OAAO,WAAW,SAAS,MAAM;AACpC,WAAW;AAAA,MACP,uBAAO,QAAQ;AAAA,EACf,WAAW,eAAe,MAAM;AACpC,GAAG,OAAO,WAAW,iBAAiB,MAAM;AAC5C,WAAW;AAAA,MACP,uBAAO,QAAQ;AAAA,EACf,WAAW,eAAe,MAAM;AACpC,GAAG,OAAO,WAAW,cAAc,MAAM;AACzC,WAAW;AAAA,MACP,uBAAO,QAAQ;AAAA,EACf,WAAW,eAAe,MAAM;AACpC,GAAG,OAAO,WAAW,kBAAkB,MAAM;AAC7C,WAAW;AAAA,MACP,uBAAO;AAAA,EACP,WAAW,eAAe,OAAO;AACrC,GAAG,OAAO,WAAW,cAAc,MAAM;AACzC,WAAW;AAAA,MACP,uBAAO;AAAA,MACP,sBAAM;AAAA,EACN,WAAW,eAAe,OAAO;AACrC,GAAG,OAAO,WAAW,oBAAoB,MAAM;AAC/C,WAAW;AAAA,MACP,uBAAO,MAAM;AAAA,EACb,WAAW,eAAe,MAAM;AACpC,GAAG,OAAO,WAAW,WAAW,MAAM;AACtC,WAAW;AAAA,MACP,uBAAO;AAAA,EACP,WAAW,eAAe,MAAM;AACpC,GAAG,OAAO,WAAW,UAAU,MAAM;AACrC,WAAW;AAAA,MACP,iCAAiB;AAAA,EACjB,WAAW,eAAe,QAAQ,KAAK,OAAO,SAAS,eAAe,UAAU,aAAa,KAAK,MAAM;AAC5G,GAAG,OAAO,WAAW,aAAa,MAAM;AACxC,WAAW;AAAA,MACP,iCAAiB;AAAA,EACjB,WAAW,eAAe,QAAQ,KAAK,OAAO,SAAS,eAAe,UAAU,aAAa,KAAK,MAAM;AAC5G,GAAG,OAAO,WAAW,aAAa,MAAM;AACxC,SAAS,WAAW;AAAA,MAChB,uBAAO,EAAE,MAAM,SAAS,CAAC;AAAA,MACzB,uBAAO,CAAC,WAAW,YAAY,CAAC;AACpC,GAAG,MAAM;;;AChHT,IAAAC,kBAA0G;;;ACYnG,SAAS,gBAAyB;AACvC,SAAO,OAAO,WAAW,eAAe,QAAQ,IAAI,aAAa;AACnE;AAOO,SAAS,wBAA6C;AAC3D,SAAO,cAAc,IAAI,SAAS;AACpC;;;ADjCA,IAAIC,cAA0C,SAAU,YAAY,QAAQ,KAAK,MAAM;AACnF,MAAI,IAAI,UAAU,QAAQ,IAAI,IAAI,IAAI,SAAS,SAAS,OAAO,OAAO,OAAO,yBAAyB,QAAQ,GAAG,IAAI,MAAM;AAC3H,MAAI,OAAO,YAAY,YAAY,OAAO,QAAQ,aAAa;AAAY,QAAI,QAAQ,SAAS,YAAY,QAAQ,KAAK,IAAI;AAAA;AACxH,aAAS,IAAI,WAAW,SAAS,GAAG,KAAK,GAAG;AAAK,UAAI,IAAI,WAAW,CAAC;AAAG,aAAK,IAAI,IAAI,EAAE,CAAC,IAAI,IAAI,IAAI,EAAE,QAAQ,KAAK,CAAC,IAAI,EAAE,QAAQ,GAAG,MAAM;AAChJ,SAAO,IAAI,KAAK,KAAK,OAAO,eAAe,QAAQ,KAAK,CAAC,GAAG;AAChE;AACA,IAAIC,cAA0C,SAAU,GAAG,GAAG;AAC1D,MAAI,OAAO,YAAY,YAAY,OAAO,QAAQ,aAAa;AAAY,WAAO,QAAQ,SAAS,GAAG,CAAC;AAC3G;AACA,IAAIC;AAAJ,IAAQC;AAAR,IAAYC;AAGZ,IAAI,cAAc,MAAMC,aAAY;AAAA,EAChC;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AACJ;AACAL,YAAW;AAAA,MACP,wCAAuB;AAAA,EACvBC,YAAW,eAAe,MAAM;AACpC,GAAG,YAAY,WAAW,MAAM,MAAM;AACtCD,YAAW;AAAA,MACP,wBAAO;AAAA,MACP,uBAAM;AAAA,EACNC,YAAW,eAAe,MAAM;AACpC,GAAG,YAAY,WAAW,YAAY,MAAM;AAC5CD,YAAW;AAAA,MACP,wBAAO;AAAA,EACPC,YAAW,eAAe,MAAM;AACpC,GAAG,YAAY,WAAW,cAAc,MAAM;AAC9CD,YAAW;AAAA,MACP,wBAAO;AAAA,EACPC,YAAW,eAAe,MAAM;AACpC,GAAG,YAAY,WAAW,iBAAiB,MAAM;AACjDD,YAAW;AAAA,MACP,wBAAO;AAAA,EACPC,YAAW,eAAe,MAAM;AACpC,GAAG,YAAY,WAAW,aAAa,MAAM;AAC7CD,YAAW;AAAA,MACP,wBAAO,sBAAsB,CAAC;AAAA,EAC9BC,YAAW,eAAe,MAAM;AACpC,GAAG,YAAY,WAAW,QAAQ,MAAM;AACxCD,YAAW;AAAA,MACP,wBAAO,QAAQ;AAAA,EACfC,YAAW,eAAe,MAAM;AACpC,GAAG,YAAY,WAAW,UAAU,MAAM;AAC1CD,YAAW;AAAA,MACP,wBAAO;AAAA,EACPC,YAAW,eAAe,MAAM;AACpC,GAAG,YAAY,WAAW,YAAY,MAAM;AAC5CD,YAAW;AAAA,MACP,wBAAO;AAAA,EACPC,YAAW,eAAe,MAAM;AACpC,GAAG,YAAY,WAAW,UAAU,MAAM;AAC1CD,YAAW;AAAA,MACP,wBAAO;AAAA,EACPC,YAAW,eAAe,QAAQC,MAAK,OAAO,SAAS,eAAe,UAAU,aAAaA,MAAK,MAAM;AAC5G,GAAG,YAAY,WAAW,cAAc,MAAM;AAC9CF,YAAW;AAAA,MACP,kCAAiB;AAAA,EACjBC,YAAW,eAAe,QAAQE,MAAK,OAAO,SAAS,eAAe,UAAU,aAAaA,MAAK,MAAM;AAC5G,GAAG,YAAY,WAAW,aAAa,MAAM;AAC7CH,YAAW;AAAA,MACP,kCAAiB;AAAA,EACjBC,YAAW,eAAe,QAAQG,MAAK,OAAO,SAAS,eAAe,UAAU,aAAaA,MAAK,MAAM;AAC5G,GAAG,YAAY,WAAW,aAAa,MAAM;AAC7C,cAAcJ,YAAW;AAAA,MACrB,wBAAO,EAAE,MAAM,eAAe,CAAC;AAAA,MAC/B,wBAAO,CAAC,YAAY,YAAY,CAAC;AACrC,GAAG,WAAW;;;AEpEd,IAAAM,kBAA2F;AAV3F,IAAIC,cAA0C,SAAU,YAAY,QAAQ,KAAK,MAAM;AACnF,MAAI,IAAI,UAAU,QAAQ,IAAI,IAAI,IAAI,SAAS,SAAS,OAAO,OAAO,OAAO,yBAAyB,QAAQ,GAAG,IAAI,MAAM;AAC3H,MAAI,OAAO,YAAY,YAAY,OAAO,QAAQ,aAAa;AAAY,QAAI,QAAQ,SAAS,YAAY,QAAQ,KAAK,IAAI;AAAA;AACxH,aAAS,IAAI,WAAW,SAAS,GAAG,KAAK,GAAG;AAAK,UAAI,IAAI,WAAW,CAAC;AAAG,aAAK,IAAI,IAAI,EAAE,CAAC,IAAI,IAAI,IAAI,EAAE,QAAQ,KAAK,CAAC,IAAI,EAAE,QAAQ,GAAG,MAAM;AAChJ,SAAO,IAAI,KAAK,KAAK,OAAO,eAAe,QAAQ,KAAK,CAAC,GAAG;AAChE;AACA,IAAIC,cAA0C,SAAU,GAAG,GAAG;AAC1D,MAAI,OAAO,YAAY,YAAY,OAAO,QAAQ,aAAa;AAAY,WAAO,QAAQ,SAAS,GAAG,CAAC;AAC3G;AACA,IAAIC;AAAJ,IAAQC;AAER,IAAI,kBAAkB,MAAMC,iBAAgB;AAAA,EACxC;AAAA,EACA;AAAA,EACA;AAAA,EACA;AAAA,EACA;AACJ;AACAJ,YAAW;AAAA,MACP,wCAAuB;AAAA,EACvBC,YAAW,eAAe,MAAM;AACpC,GAAG,gBAAgB,WAAW,MAAM,MAAM;AAC1CD,YAAW;AAAA,MACP,wBAAO,EAAE,QAAQ,KAAK,CAAC;AAAA,EACvBC,YAAW,eAAe,MAAM;AACpC,GAAG,gBAAgB,WAAW,aAAa,MAAM;AACjDD,YAAW;AAAA,MACP,wBAAO;AAAA,EACPC,YAAW,eAAe,MAAM;AACpC,GAAG,gBAAgB,WAAW,cAAc,MAAM;AAClDD,YAAW;AAAA,MACP,kCAAiB;AAAA,EACjBC,YAAW,eAAe,QAAQC,MAAK,OAAO,SAAS,eAAe,UAAU,aAAaA,MAAK,MAAM;AAC5G,GAAG,gBAAgB,WAAW,aAAa,MAAM;AACjDF,YAAW;AAAA,MACP,kCAAiB;AAAA,EACjBC,YAAW,eAAe,QAAQE,MAAK,OAAO,SAAS,eAAe,UAAU,aAAaA,MAAK,MAAM;AAC5G,GAAG,gBAAgB,WAAW,aAAa,MAAM;AACjD,kBAAkBH,YAAW;AAAA,MACzB,wBAAO,EAAE,MAAM,mBAAmB,CAAC;AACvC,GAAG,eAAe;;;ACxClB,IAAAK,kBAA2B;AAIpB,IAAM,YAAN,MAAgB;AAAA,EAGX,YACS,gBACA,UACjB;AAFiB;AACA;AAAA,EAChB;AAAA,EALH;AAAA,EAOA,MAAgB,OAAO;AACrB,UAAM,SAAS,OAAO,KAAK,mBAAmB,aAAa,MAAM,KAAK,eAAe,IAAI,KAAK;AAC9F,SAAK,aAAa,IAAI,2BAAW;AAAA,MAC/B,GAAG;AAAA;AAAA,MAGH,aAAa;AAAA,MACb,YAAY;AAAA;AAAA,MAGZ,UAAU,KAAK;AAAA,IACjB,CAAC;AACD,UAAM,KAAK,WAAW,WAAW;AAAA,EACnC;AAAA,EAEA,MAAM,YAAY,gBAAyB;AACzC,UAAM,KAAK,WAAW,YAAY,cAAc;AAAA,EAClD;AAAA,EAEA,MAAM,QAAQ;AACZ,UAAM,KAAK,WAAW,QAAQ;AAAA,EAChC;AAAA,EAEA,gBAAgB;AACd,WAAO,KAAK,WAAW;AAAA,EACzB;AACF;;;AC9BO,IAAM,cAAN,MAAM,qBAAoB,UAAU;AAAA,EACzC;AAAA,EAEA;AAAA,EAEA;AAAA,EAEU,YAAY,gBAAqC;AACzD,UAAM,gBAAgB,CAAC,QAAQ,aAAa,eAAe,CAAC;AAAA,EAC9D;AAAA,EAEA,MAAgB,OAAO;AACrB,UAAM,MAAM,KAAK;AAEjB,SAAK,SAAS,KAAK,WAAW,cAAc,MAAM;AAClD,SAAK,cAAc,KAAK,WAAW,cAAc,WAAW;AAC5D,SAAK,kBAAkB,KAAK,WAAW,cAAc,eAAe;AAAA,EACtE;AAAA,EAEA,aAAa,IAAI,QAAqB;AACpC,UAAM,SAAS,IAAI,aAAY,MAAM;AACrC,UAAM,OAAO,KAAK;AAElB,WAAO;AAAA,EACT;AACF;","names":["Stream","import_typeorm","__decorate","__metadata","_a","_b","_c","StreamEvent","import_typeorm","__decorate","__metadata","_a","_b","StreamProcessor","import_typeorm"]}