feature: add initial chaincode

Author: mostafa6765

.eslintignore

@@ -0,0 +1,5 @@
+#
+# SPDX-License-Identifier: Apache-2.0
+#
+
+coverage

.eslintrc.js

@@ -0,0 +1,39 @@
+/*
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+module.exports = {
+    env: {
+        node: true,
+        mocha: true,
+        es6: true
+    },
+    parserOptions: {
+        ecmaVersion: 8,
+        sourceType: 'script'
+    },
+    extends: "eslint:recommended",
+    rules: {
+        indent: ['error', 4],
+        'linebreak-style': ['error', 'unix'],
+        quotes: ['error', 'single'],
+        semi: ['error', 'always'],
+        'no-unused-vars': ['error', { args: 'none' }],
+        'no-console': 'off',
+        curly: 'error',
+        eqeqeq: 'error',
+        'no-throw-literal': 'error',
+        strict: 'error',
+        'no-var': 'error',
+        'dot-notation': 'error',
+        'no-tabs': 'error',
+        'no-trailing-spaces': 'error',
+        'no-use-before-define': 'error',
+        'no-useless-call': 'error',
+        'no-with': 'error',
+        'operator-linebreak': 'error',
+        yoda: 'error',
+        'quote-props': ['error', 'as-needed'],
+        'no-constant-condition': ["error", { "checkLoops": false }]
+    }
+};

.gitignore

@@ -0,0 +1,18 @@
+#
+# SPDX-License-Identifier: Apache-2.0
+#
+
+# Coverage directory used by tools like istanbul
+coverage
+
+# Report cache used by istanbul
+.nyc_output
+
+# Dependency directories
+node_modules/
+jspm_packages/
+
+package-lock.json
+
+# zip
+chaincode-javascript.zip

index.js

@@ -0,0 +1,12 @@
+/*
+ * Copyright IBM Corp. All Rights Reserved.
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+'use strict';
+
+const propertyAsset = require('./lib/propertyAsset');
+
+module.exports.PropertyAsset = propertyAsset;
+module.exports.contracts = [propertyAsset];

lib/propertyAsset.js

@@ -0,0 +1,177 @@
+/*
+ * Copyright IBM Corp. All Rights Reserved.
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+'use strict';
+
+// Deterministic JSON.stringify()
+const stringify  = require('json-stringify-deterministic');
+const sortKeysRecursive  = require('sort-keys-recursive');
+const { Contract } = require('fabric-contract-api');
+const { v4: uuidv4 } = require('uuid');
+
+class PropertyAsset extends Contract {
+    // Initialize Ledger
+    async InitLedger(ctx) {
+        // Create property IDs first
+        const property1Id = uuidv4();
+        const property2Id = uuidv4();
+        const property3Id = uuidv4();
+
+        const assets = [
+            {
+                PropertyID: property1Id,
+                Name: 'Asset One',
+                Quantity: 100,
+                Price: 299.99,
+                Image: 'asset1.jpg',
+            },
+            {
+                PropertyID: property1Id,
+                Name: 'Asset Two',
+                Quantity: 50,
+                Price: 499.99,
+                Image: 'asset2.jpg',
+            },
+            {
+                PropertyID: property2Id,
+                Name: 'Asset Three',
+                Quantity: 75,
+                Price: 199.99,
+                Image: 'asset3.jpg',
+            },
+            {
+                PropertyID: property2Id,
+                Name: 'Asset Four',
+                Quantity: 200,
+                Price: 399.99,
+                Image: 'asset4.jpg',
+            },
+            {
+                PropertyID: property3Id,
+                Name: 'Asset Five',
+                Quantity: 150,
+                Price: 599.99,
+                Image: 'asset5.jpg',
+            },
+            {
+                PropertyID: property3Id,
+                Name: 'Asset Six',
+                Quantity: 80,
+                Price: 699.99,
+                Image: 'asset6.jpg',
+            },
+        ];
+
+        for (const asset of assets) {
+            const id = uuidv4();
+            asset.ID = id;
+            asset.docType = 'asset';
+            asset.CreatedAt = new Date().toISOString();
+            
+            await ctx.stub.putState(id, Buffer.from(stringify(sortKeysRecursive(asset))));
+        }
+    }
+
+    // Asset CRUD Operations
+    // ====================================
+
+    async CreateAsset(ctx, propertyId, name, quantity, price, image) {
+        const id = uuidv4();
+        const exists = await this.AssetExists(ctx, id);
+        if (exists) {
+            throw new Error(`The asset ${id} already exists`);
+        }
+
+        const asset = {
+            ID: id,
+            PropertyID: propertyId,
+            Name: name,
+            Quantity: parseInt(quantity),
+            Price: parseFloat(price),
+            Image: image,
+            docType: 'asset',
+            CreatedAt: new Date().toISOString(),
+        };
+        
+        await ctx.stub.putState(id, Buffer.from(stringify(sortKeysRecursive(asset))));
+        return JSON.stringify(asset);
+    }
+
+    async ReadAsset(ctx, id) {
+        const assetJSON = await ctx.stub.getState(id);
+        if (!assetJSON || assetJSON.length === 0) {
+            throw new Error(`The asset ${id} does not exist`);
+        }
+        return assetJSON.toString();
+    }
+
+    async UpdateAsset(ctx, id, propertyId, name, quantity, price, image) {
+        const exists = await this.AssetExists(ctx, id);
+        if (!exists) {
+            throw new Error(`The asset ${id} does not exist`);
+        }
+
+        const updatedAsset = {
+            ID: id,
+            PropertyID: propertyId,
+            Name: name,
+            Quantity: parseInt(quantity),
+            Price: parseFloat(price),
+            Image: image,
+            docType: 'asset',
+            UpdatedAt: new Date().toISOString(),
+        };
+        
+        await ctx.stub.putState(id, Buffer.from(stringify(sortKeysRecursive(updatedAsset))));
+        return JSON.stringify(updatedAsset);
+    }
+
+    async DeleteAsset(ctx, id) {
+        const exists = await this.AssetExists(ctx, id);
+        if (!exists) {
+            throw new Error(`The asset ${id} does not exist`);
+        }
+        return ctx.stub.deleteState(id);
+    }
+
+    // Query Operations
+    // ====================================
+
+    async GetAllAssets(ctx, propertyId) {
+        const allResults = [];
+        const iterator = await ctx.stub.getStateByRange('', '');
+        let result = await iterator.next();
+        while (!result.done) {
+            const strValue = Buffer.from(result.value.value.toString()).toString('utf8');
+            let record;
+            try {
+                record = JSON.parse(strValue);
+                // Only add records that match the propertyId
+                if (propertyId && record.PropertyID === propertyId) {
+                    allResults.push(record);
+                } else if (!propertyId) {
+                    // If no propertyId is provided, return all assets
+                    allResults.push(record);
+                }
+            } catch (err) {
+                console.log(err);
+                record = strValue;
+            }
+            result = await iterator.next();
+        }
+        return JSON.stringify(allResults);
+    }
+
+    // Helper Methods
+    // ====================================
+
+    async AssetExists(ctx, id) {
+        const assetJSON = await ctx.stub.getState(id);
+        return assetJSON && assetJSON.length > 0;
+    }
+}
+
+module.exports = PropertyAsset;