[WIP] Paranet sync rework

src/modules/repository/implementation/sequelize/migrations/20241215122200-create-paranet-assets.js

@@ -0,0 +1,65 @@
+export async function up({ context: { queryInterface, Sequelize } }) {
+    await queryInterface.createTable('paranet_asset', {
+        id: {
+            type: Sequelize.INTEGER,
+            primaryKey: true,
+            autoIncrement: true,
+        },
+        blockchain_id: {
+            type: Sequelize.STRING,
+            allowNull: false,
+        },
+        ual: {
+            type: Sequelize.STRING,
+            allowNull: false,
+        },
+        paranet_ual: {
+            type: Sequelize.STRING,
+            allowNull: false,
+        },
+        public_assertion_id: {
+            type: Sequelize.STRING,
+            allowNull: true,
+        },
+        private_assertion_id: {
+            type: Sequelize.STRING,
+            allowNull: true,
+        },
+        sender: {
+            type: Sequelize.STRING,
+            allowNull: true,
+        },
+        transaction_hash: {
+            type: Sequelize.STRING,
+            allowNull: true,
+        },
+        error_message: {
+            type: Sequelize.TEXT,
+            allowNull: true,
+        },
+        is_synced: {
+            type: Sequelize.BOOLEAN,
+            allowNull: false,
+            defaultValue: false,
+        },
+        retries: {
+            allowNull: false,
+            type: Sequelize.INTEGER,
+            defaultValue: 0,
+        },
+        created_at: {
+            allowNull: false,
+            type: Sequelize.DATE,
+            defaultValue: Sequelize.literal('NOW()'),
+        },
+        updated_at: {
+            allowNull: false,
+            type: Sequelize.DATE,
+            defaultValue: Sequelize.literal('NOW()'),
+        },
+    });
+}
+
+export async function down({ context: { queryInterface } }) {
+    await queryInterface.dropTable('paranet_assets');
+}

src/modules/repository/implementation/sequelize/models/missed-paranet-asset.js

@@ -1,3 +1,5 @@
+// NOT USED ANYMORE
+
 export default (sequelize, DataTypes) => {
     const blockchain = sequelize.define(
         'missed_paranet_asset',

src/modules/repository/implementation/sequelize/models/paranet-asset.js

@@ -0,0 +1,84 @@
+export default (sequelize, DataTypes) => {
+    const paranetAsset = sequelize.define(
+        'paranet_asset',
+        {
+            id: {
+                autoIncrement: true,
+                primaryKey: true,
+                type: DataTypes.INTEGER,
+            },
+            blockchainId: {
+                allowNull: false,
+                type: DataTypes.STRING,
+            },
+            ual: {
+                allowNull: false,
+                type: DataTypes.STRING,
+            },
+            paranetUal: {
+                allowNull: false,
+                type: DataTypes.STRING,
+            },
+            publicAssertionId: {
+                allowNull: true,
+                type: DataTypes.STRING,
+            },
+            privateAssertionId: {
+                allowNull: true,
+                type: DataTypes.STRING,
+            },
+            sender: {
+                allowNull: true,
+                type: DataTypes.STRING,
+            },
+            transactionHash: {
+                allowNull: true,
+                type: DataTypes.STRING,
+            },
+            errorMessage: {
+                allowNull: true,
+                type: DataTypes.TEXT,
+            },
+            isSynced: {
+                allowNull: false,
+                type: DataTypes.BOOLEAN,
+                defaultValue: false,
+            },
+            retries: {
+                allowNull: false,
+                type: DataTypes.INTEGER,
+                defaultValue: 0,
+            },
+            createdAt: {
+                type: DataTypes.DATE,
+            },
+            updatedAt: {
+                type: DataTypes.DATE,
+            },
+        },
+        {
+            underscored: true,
+            indexes: [
+                {
+                    unique: true,
+                    fields: ['ual', 'paranetUal'], // Composite unique constraint on `ual` and `paranetUal`
+                },
+                {
+                    fields: ['updatedAt', 'retries', 'isSynced'],
+                },
+                {
+                    fields: ['ual', 'paranetUal'],
+                },
+                {
+                    fields: ['isSynced', 'paranetUal'],
+                },
+            ],
+        },
+    );
+
+    paranetAsset.associate = () => {
+        // Define associations here if needed
+    };
+
+    return paranetAsset;
+};

src/modules/repository/implementation/sequelize/models/paranet-synced-asset.js

@@ -1,5 +1,6 @@
 import { PARANET_SYNC_SOURCES } from '../../../../../constants/constants.js';
 
+// NOT USED ANYMORE
 export default (sequelize, DataTypes) => {
     const blockchain = sequelize.define(
         'paranet_synced_asset',

src/modules/repository/implementation/sequelize/repositories/paranet-asset-repository.js

@@ -0,0 +1,139 @@
+import Sequelize from 'sequelize';
+
+class ParanetAssetRepository {
+    constructor(models) {
+        this.sequelize = models.sequelize;
+        this.model = models.paranet_asset;
+    }
+
+    async createParanetAssetRecord(missedParanetAsset, options) {
+        return this.model.create({ ...missedParanetAsset, isSynced: false }, options);
+    }
+
+    async getCountOfMissedAssetsOfParanet(paranetUal, options = {}) {
+        return this.model.count({
+            where: {
+                paranetUal,
+                isSynced: false,
+            },
+            ...options,
+        });
+    }
+
+    async getParanetSyncedAssetRecordsCount(paranetUal, options = {}) {
+        return this.model.count({
+            where: {
+                paranet_ual: paranetUal,
+                isSynced: true,
+            },
+            ...options,
+        });
+    }
+
+    // TODO: remove
+    // async getFilteredCountOfMissedAssetsOfParanet(
+    //     paranetUal,
+    //     retryCountLimit,
+    //     retryDelayInMs,
+    //     options = {},
+    // ) {
+    //     const now = new Date();
+    //     const delayDate = new Date(now.getTime() - retryDelayInMs);
+
+    //     const records = await this.model.findAll({
+    //         where: {
+    //             paranetUal,
+    //             isSynced: false, // Only unsynced assets
+    //             retries: {
+    //                 [Sequelize.Op.lt]: retryCountLimit, // Filter by retries count
+    //             },
+    //             created_at: {
+    //                 [Sequelize.Op.lte]: delayDate, // Filter by created_at date
+    //             },
+    //         },
+    //         ...options,
+    //     });
+
+    //     return records.length; // Return the count of matching records
+    // }
+
+    async getMissedParanetAssetsRecordsWithRetryCount(
+        paranetUal,
+        retryCountLimit,
+        retryDelayInMs,
+        limit = null,
+        options = {},
+    ) {
+        const now = new Date();
+        const delayDate = new Date(now.getTime() - retryDelayInMs);
+
+        const queryOptions = {
+            where: {
+                paranetUal,
+                isSynced: false,
+                retries: {
+                    [Sequelize.Op.lt]: retryCountLimit,
+                },
+                updated_at: {
+                    [Sequelize.Op.lte]: delayDate,
+                },
+            },
+            ...options,
+        };
+
+        if (limit !== null) {
+            queryOptions.limit = limit;
+        }
+
+        return this.model.findAll(queryOptions);
+    }
+
+    async missedParanetAssetRecordExists(ual, paranetUal, options = {}) {
+        const missedParanetAssetRecord = await this.model.findOne({
+            where: { ual, isSynced: false },
+            ...options,
+        });
+
+        return !!missedParanetAssetRecord;
+    }
+
+    async paranetSyncedAssetRecordExists(ual, paranetUal, options = {}) {
+        const paranetSyncedAssetRecord = await this.model.getParanetSyncedAssetRecordByUAL(
+            ual,
+            paranetUal,
+            options,
+        );
+
+        return !!paranetSyncedAssetRecord;
+    }
+
+    async updateAssetToBeSynced(ual, paranetUal, options = {}) {
+        const [affectedRows] = await this.model.update(
+            { isSynced: true },
+            {
+                where: {
+                    ual,
+                    paranetUal,
+                },
+                ...options,
+            },
+        );
+
+        return affectedRows;
+    }
+
+    async incrementRetriesForUalAndParanetUal(ual, paranetUal, options = {}) {
+        const [affectedRows] = await this.model.increment('retries', {
+            by: 1,
+            where: {
+                ual,
+                paranetUal,
+            },
+            ...options,
+        });
+
+        return affectedRows;
+    }
+}
+
+export default ParanetAssetRepository;

src/modules/repository/implementation/sequelize/repositories/paranet-synced-asset-repository.js

@@ -1,3 +1,4 @@
+// DEPRECATED
 class ParanetSyncedAssetRepository {
     constructor(models) {
         this.sequelize = models.sequelize;