tx · GZtrLmwpweSUDTLzjPPuKXa8M8dQXoQUWpcnJChWEkaF 3N9tKixzqTYWnEXQxrDQ5pBTGvQd6sFsvmV: -0.05000000 Waves 2024.10.28 10:20 [3346414] smart account 3N9tKixzqTYWnEXQxrDQ5pBTGvQd6sFsvmV > SELF 0.00000000 Waves
{ "type": 13, "id": "GZtrLmwpweSUDTLzjPPuKXa8M8dQXoQUWpcnJChWEkaF", "fee": 5000000, "feeAssetId": null, "timestamp": 1730100027208, "version": 2, "chainId": 84, "sender": "3N9tKixzqTYWnEXQxrDQ5pBTGvQd6sFsvmV", "senderPublicKey": "DS6HkopS9zypvxX6VhkdNvv6v4wcPZuChRvTwKJeacxE", "proofs": [ "64mJrgSznUpGLdYK33sKKVj7M6tqAc6y2CmuWCHdJNJWo91QT7DRPosTsfGEBZbE7cB6cPepLLSFgh8nvNznpv9u" ], "script": "base64:BgIbCAISBAoCCAgSBQoDCAgIEgQKAggIEgQKAggIDAARQUlfVE9LRU5fQVNTRVRfSUQBIJPhcjhxBJtq6JpjHwQkt2RTlyw+vGYLg3SvaLskjeJCAAtTVEFUVVNfT1BFTgIEb3BlbgASU1RBVFVTX0NIRUNLRURfT1VUAgtjaGVja2VkX291dAALU1RBVFVTX0RPTkUCBGRvbmUADkNIRUNLRURfT1VUX0JZAhBfY2hlY2tlZF9vdXRfYnlfABNTSU1QTEVfQ0hBVEdQVF9UQVNLAhNzaW1wbGVfQ2hhdEdQVF90YXNrABBDSEVDS19PVVRfSEVJR0hUAhJfY2hlY2tfb3V0X2hlaWdodF8AD1JFR0lTVEVSX0hFSUdIVAIRX3JlZ2lzdGVyX2hlaWdodF8ADUNPTU1JVF9IRUlHSFQCD19jb21taXRfaGVpZ2h0XwEPY2FuQmVDaGVja2VkT3V0AgZ0YXNrSWQEdHlwZQQGc3RhdHVzCQCdCAIFBHRoaXMJAKwCAgkArAICBQZ0YXNrSWQCCF9zdGF0dXNfBQR0eXBlCQAAAgUGc3RhdHVzBQtTVEFUVVNfT1BFTgEOaXNDb3JyZWN0QWdlbnQDBnRhc2tJZAdhZ2VudElkBHR5cGUED2NoZWNrb3V0QWdlbnRJZAkAnQgCBQR0aGlzCQCsAgIJAKwCAgUGdGFza0lkBQ5DSEVDS0VEX09VVF9CWQUEdHlwZQkAAAIFD2NoZWNrb3V0QWdlbnRJZAUHYWdlbnRJZAEPZ2V0UHJpY2VGb3JUeXBlAQR0eXBlBAckbWF0Y2gwCQCaCAIFBHRoaXMJAKwCAgIGcHJpY2VfBQR0eXBlAwkAAQIFByRtYXRjaDACA0ludAQBaQUHJG1hdGNoMAUBaQD///////////8BBAFpAQxyZWdpc3RlclRhc2sCC2Rlc2NyaXB0aW9uBHR5cGUEEG51bWJlck9mUGF5bWVudHMJAJADAQgFAWkIcGF5bWVudHMDCQECIT0CBRBudW1iZXJPZlBheW1lbnRzAAEJAAIBAhJQYXltZW50IG5lY2Vzc2FyeSEED2NhbGxlclB1YmxpY0tleQkA2AQBCAUBaQ9jYWxsZXJQdWJsaWNLZXkEBHR4SWQJANgEAQgFAWkNdHJhbnNhY3Rpb25JZAQHcGF5bWVudAkAkQMCCAUBaQhwYXltZW50cwAABANmZWUIBQdwYXltZW50BmFtb3VudAQKZmVlQXNzZXRJZAgFB3BheW1lbnQHYXNzZXRJZAQGdGFza0lkCQCsAgIJAKwCAgUEdHhJZAIBXwUPY2FsbGVyUHVibGljS2V5BAl0aW1lc3RhbXAIBQlsYXN0QmxvY2sJdGltZXN0YW1wBAZtaW5GZWUJAQ9nZXRQcmljZUZvclR5cGUBBQR0eXBlBAxkYW9Vc2VyVmFsdWUEByRtYXRjaDAJAJoIAgUEdGhpcwkArAICAglkYW9fdXNlcl8FD2NhbGxlclB1YmxpY0tleQMJAAECBQckbWF0Y2gwAgNJbnQEAW4FByRtYXRjaDAJAGQCBQFuBQNmZWUFA2ZlZQQGZGFvU3VtBAckbWF0Y2gwCQCaCAIFBHRoaXMCB2Rhb19zdW0DCQABAgUHJG1hdGNoMAIDSW50BAFuBQckbWF0Y2gwCQBkAgUBbgUDZmVlBQNmZWUDCQECIT0CBQpmZWVBc3NldElkBRFBSV9UT0tFTl9BU1NFVF9JRAkAAgECJlBheW1lbnQgb25seSBwb3NzaWJsZSBpbiB0aGUgQUkgVG9rZW4hAwkAAAIFBm1pbkZlZQD///////////8BCQACAQIYVGFzayB0eXBlIG5vdCBzdXBwb3J0ZWQhAwkAZgIFBm1pbkZlZQUDZmVlCQACAQkArAICCQCsAgICHVBheW1lbnQgbmVlZHMgdG8gYmUgYXQgbGVhc3QgCQCkAwEFBm1pbkZlZQILIEJBSSBUb2tlbiEJAMwIAgkBC1N0cmluZ0VudHJ5AgkArAICCQCsAgIFBnRhc2tJZAINX2Rlc2NyaXB0aW9uXwUEdHlwZQULZGVzY3JpcHRpb24JAMwIAgkBC1N0cmluZ0VudHJ5AgkArAICCQCsAgIFBHR4SWQCDV9pbml0aWFsaXplcl8FBHR5cGUFD2NhbGxlclB1YmxpY0tleQkAzAgCCQELU3RyaW5nRW50cnkCCQCsAgIJAKwCAgUGdGFza0lkAghfc3RhdHVzXwUEdHlwZQULU1RBVFVTX09QRU4JAMwIAgkBC1N0cmluZ0VudHJ5AgkArAICBQZ0YXNrSWQCBV90eXBlBQR0eXBlCQDMCAIJAQxJbnRlZ2VyRW50cnkCCQCsAgIJAKwCAgUGdGFza0lkBQ9SRUdJU1RFUl9IRUlHSFQFBHR5cGUFBmhlaWdodAkAzAgCCQEMSW50ZWdlckVudHJ5AgkArAICCQCsAgIFBnRhc2tJZAIUX3JlZ2lzdGVyX3RpbWVzdGFtcF8FBHR5cGUFCXRpbWVzdGFtcAkAzAgCCQEMQm9vbGVhbkVudHJ5AgkArAICCQCsAgIJAKwCAgIFb3Blbl8FBHR5cGUCAV8FBnRhc2tJZAYJAMwIAgkBDEludGVnZXJFbnRyeQICB2Rhb19zdW0FBmRhb1N1bQkAzAgCCQEMSW50ZWdlckVudHJ5AgkArAICAglkYW9fdXNlcl8FD2NhbGxlclB1YmxpY0tleQUMZGFvVXNlclZhbHVlBQNuaWwBaQEUcmVnaXN0ZXJUYXNrQ2FsbGJhY2sDC2Rlc2NyaXB0aW9uBHR5cGUIY2FsbGJhY2sEEG51bWJlck9mUGF5bWVudHMJAJADAQgFAWkIcGF5bWVudHMDCQECIT0CBRBudW1iZXJPZlBheW1lbnRzAAEJAAIBAhJQYXltZW50IG5lY2Vzc2FyeSEED2NhbGxlclB1YmxpY0tleQkA2AQBCAUBaQ9jYWxsZXJQdWJsaWNLZXkEBmNhbGxlcgkApQgBCAUBaQZjYWxsZXIEBHR4SWQJANgEAQgFAWkNdHJhbnNhY3Rpb25JZAQHcGF5bWVudAkAkQMCCAUBaQhwYXltZW50cwAABANmZWUIBQdwYXltZW50BmFtb3VudAQKZmVlQXNzZXRJZAgFB3BheW1lbnQHYXNzZXRJZAQGdGFza0lkCQCsAgIJAKwCAgUEdHhJZAIBXwUPY2FsbGVyUHVibGljS2V5BAl0aW1lc3RhbXAIBQlsYXN0QmxvY2sJdGltZXN0YW1wBAZtaW5GZWUJAQ9nZXRQcmljZUZvclR5cGUBBQR0eXBlAwkBAiE9AgUKZmVlQXNzZXRJZAURQUlfVE9LRU5fQVNTRVRfSUQJAAIBAiZQYXltZW50IG9ubHkgcG9zc2libGUgaW4gdGhlIEFJIFRva2VuIQMJAAACBQZtaW5GZWUA////////////AQkAAgECGFRhc2sgdHlwZSBub3Qgc3VwcG9ydGVkIQMJAGYCBQZtaW5GZWUFA2ZlZQkAAgEJAKwCAgkArAICAh1QYXltZW50IG5lZWRzIHRvIGJlIGF0IGxlYXN0IAkApAMBBQZtaW5GZWUCCyBCQUkgVG9rZW4hCQCUCgIJAMwIAgkBC1N0cmluZ0VudHJ5AgkArAICCQCsAgIFBnRhc2tJZAINX2Rlc2NyaXB0aW9uXwUEdHlwZQULZGVzY3JpcHRpb24JAMwIAgkBC1N0cmluZ0VudHJ5AgkArAICCQCsAgIFBHR4SWQCDV9pbml0aWFsaXplcl8FBHR5cGUFD2NhbGxlclB1YmxpY0tleQkAzAgCCQELU3RyaW5nRW50cnkCCQCsAgIJAKwCAgUGdGFza0lkAgpfY2FsbGJhY2tfBQR0eXBlBQhjYWxsYmFjawkAzAgCCQELU3RyaW5nRW50cnkCCQCsAgIJAKwCAgUGdGFza0lkAghfY2FsbGVyXwUEdHlwZQUGY2FsbGVyCQDMCAIJAQtTdHJpbmdFbnRyeQIJAKwCAgkArAICBQZ0YXNrSWQCCF9zdGF0dXNfBQR0eXBlBQtTVEFUVVNfT1BFTgkAzAgCCQELU3RyaW5nRW50cnkCCQCsAgIFBnRhc2tJZAIFX3R5cGUFBHR5cGUJAMwIAgkBDEludGVnZXJFbnRyeQIJAKwCAgkArAICBQZ0YXNrSWQFD1JFR0lTVEVSX0hFSUdIVAUEdHlwZQUGaGVpZ2h0CQDMCAIJAQxJbnRlZ2VyRW50cnkCCQCsAgIJAKwCAgUGdGFza0lkAhRfcmVnaXN0ZXJfdGltZXN0YW1wXwUEdHlwZQUJdGltZXN0YW1wCQDMCAIJAQxCb29sZWFuRW50cnkCCQCsAgIJAKwCAgkArAICAgVvcGVuXwUEdHlwZQIBXwUGdGFza0lkBgkAzAgCCQELU3RyaW5nRW50cnkCCQCsAgIJAKwCAgkArAICAhRjYWxsYmFja19hY2NvdW50aW5nXwUEdHhJZAIBXwkApAMBBQZoZWlnaHQFBnRhc2tJZAUDbmlsBQZ0YXNrSWQBaQEMY2hlY2tvdXRUYXNrAgZ0YXNrSWQEdHlwZQQPY2FsbGVyUHVibGljS2V5CQDYBAEIBQFpD2NhbGxlclB1YmxpY0tleQQNdGFza1N0aWxsT3BlbgkBD2NhbkJlQ2hlY2tlZE91dAIFBnRhc2tJZAUEdHlwZQQJdGltZXN0YW1wCAUJbGFzdEJsb2NrCXRpbWVzdGFtcAMJAQEhAQUNdGFza1N0aWxsT3BlbgkAAgECG1Rhc2sgbm90IG9wZW4gZm9yIGNoZWNrb3V0IQkAzAgCCQELU3RyaW5nRW50cnkCCQCsAgIJAKwCAgUGdGFza0lkBQ5DSEVDS0VEX09VVF9CWQUEdHlwZQUPY2FsbGVyUHVibGljS2V5CQDMCAIJAQtTdHJpbmdFbnRyeQIJAKwCAgkArAICBQZ0YXNrSWQCCF9zdGF0dXNfBQR0eXBlBRJTVEFUVVNfQ0hFQ0tFRF9PVVQJAMwIAgkBDEludGVnZXJFbnRyeQIJAKwCAgkArAICBQZ0YXNrSWQFEENIRUNLX09VVF9IRUlHSFQFBHR5cGUFBmhlaWdodAkAzAgCCQEMSW50ZWdlckVudHJ5AgkArAICCQCsAgIFBnRhc2tJZAIVX2NoZWNrX291dF90aW1lc3RhbXBfBQR0eXBlBQl0aW1lc3RhbXAJAMwIAgkBDEJvb2xlYW5FbnRyeQIJAKwCAgkArAICCQCsAgIJAKwCAgkArAICAg9jaGVja2VkX291dF9ieV8FD2NhbGxlclB1YmxpY0tleQIBXwUEdHlwZQIBXwUGdGFza0lkBgkAzAgCCQELRGVsZXRlRW50cnkBCQCsAgIJAKwCAgkArAICAgVvcGVuXwUEdHlwZQIBXwUGdGFza0lkBQNuaWwBaQEKY29tbWl0VGFzawIGdGFza0lkCHJlc3BvbnNlBA9jYWxsZXJQdWJsaWNLZXkJANgEAQgFAWkPY2FsbGVyUHVibGljS2V5BAR0eXBlBAckbWF0Y2gwCQCiCAEJAKwCAgUGdGFza0lkAgVfdHlwZQMJAAECBQckbWF0Y2gwAgZTdHJpbmcEAXMFByRtYXRjaDAFAXMCB25vdCBzZXQEDGNvcnJlY3RBZ2VudAkBDmlzQ29ycmVjdEFnZW50AwUGdGFza0lkBQ9jYWxsZXJQdWJsaWNLZXkFBHR5cGUECXRpbWVzdGFtcAgFCWxhc3RCbG9jawl0aW1lc3RhbXAECGNhbGxiYWNrBAckbWF0Y2gwCQCiCAEJAKwCAgkArAICBQZ0YXNrSWQCCl9jYWxsYmFja18FBHR5cGUDCQABAgUHJG1hdGNoMAIGU3RyaW5nBAFzBQckbWF0Y2gwBQFzAgtubyBjYWxsYmFjawQGY2FsbGVyBAckbWF0Y2gwCQCiCAEJAKwCAgkArAICBQZ0YXNrSWQCCF9jYWxsZXJfBQR0eXBlAwkAAQIFByRtYXRjaDACBlN0cmluZwQBcwUHJG1hdGNoMAUBcwILbm8gY2FsbGJhY2sDCQEBIQEFDGNvcnJlY3RBZ2VudAkAAgECQVRhc2sgbWF5IG9ubHkgYmUgc3VibWl0dGVkIGJ5IHRoZSBhZ2VudCB3aG8gY2hlY2tlZCB0aGUgdGFzayBvdXQhAwkAAAIFBHR5cGUCB25vdCBzZXQJAAIBAiBDYW4gbm90IGlkZW50aWZ5IHR5cGUgb2YgdGFzayBpZAMJAQIhPQIFCGNhbGxiYWNrAgtubyBjYWxsYmFjawQGcmVzdWx0CQD8BwQJAQdBZGRyZXNzAQkA2QQBBQZjYWxsZXIFCGNhbGxiYWNrCQDMCAIFBnRhc2tJZAkAzAgCBQhyZXNwb25zZQUDbmlsBQNuaWwDCQAAAgUGcmVzdWx0BQZyZXN1bHQJAMwIAgkBC1N0cmluZ0VudHJ5AgkArAICCQCsAgIFBnRhc2tJZAIIX3N0YXR1c18FBHR5cGUFC1NUQVRVU19ET05FCQDMCAIJAQtTdHJpbmdFbnRyeQIJAKwCAgkArAICBQZ0YXNrSWQCCF9yZXN1bHRfBQR0eXBlBQhyZXNwb25zZQkAzAgCCQEMSW50ZWdlckVudHJ5AgkArAICCQCsAgIFBnRhc2tJZAUNQ09NTUlUX0hFSUdIVAUEdHlwZQUGaGVpZ2h0CQDMCAIJAQxJbnRlZ2VyRW50cnkCCQCsAgIJAKwCAgUGdGFza0lkAhJfY29tbWl0X3RpbWVzdGFtcF8FBHR5cGUFCXRpbWVzdGFtcAkAzAgCCQELRGVsZXRlRW50cnkBCQCsAgIJAKwCAgkArAICCQCsAgIJAKwCAgIPY2hlY2tlZF9vdXRfYnlfBQ9jYWxsZXJQdWJsaWNLZXkCAV8FBHR5cGUCAV8FBnRhc2tJZAUDbmlsCQACAQIkU3RyaWN0IHZhbHVlIGlzIG5vdCBlcXVhbCB0byBpdHNlbGYuCQDMCAIJAQtTdHJpbmdFbnRyeQIJAKwCAgkArAICBQZ0YXNrSWQCCF9zdGF0dXNfBQR0eXBlBQtTVEFUVVNfRE9ORQkAzAgCCQELU3RyaW5nRW50cnkCCQCsAgIJAKwCAgUGdGFza0lkAghfcmVzdWx0XwUEdHlwZQUIcmVzcG9uc2UJAMwIAgkBDEludGVnZXJFbnRyeQIJAKwCAgkArAICBQZ0YXNrSWQFDUNPTU1JVF9IRUlHSFQFBHR5cGUFBmhlaWdodAkAzAgCCQEMSW50ZWdlckVudHJ5AgkArAICCQCsAgIFBnRhc2tJZAISX2NvbW1pdF90aW1lc3RhbXBfBQR0eXBlBQl0aW1lc3RhbXAJAMwIAgkBC0RlbGV0ZUVudHJ5AQkArAICCQCsAgIJAKwCAgkArAICCQCsAgICD2NoZWNrZWRfb3V0X2J5XwUPY2FsbGVyUHVibGljS2V5AgFfBQR0eXBlAgFfBQZ0YXNrSWQFA25pbAECdHgBBnZlcmlmeQAJAPQDAwgFAnR4CWJvZHlCeXRlcwkAkQMCCAUCdHgGcHJvb2ZzAAAIBQJ0eA9zZW5kZXJQdWJsaWNLZXkmP4uL", "height": 3346414, "applicationStatus": "succeeded", "spentComplexity": 0 } View: original | compacted Prev: 8FfhZKXNXG9SNHYDcsrANSKfKaSobwU281H5wQXSCBMo Next: none Diff:
Old | New | Differences | |
---|---|---|---|
1 | - | {-# STDLIB_VERSION | |
1 | + | {-# STDLIB_VERSION 6 #-} | |
2 | 2 | {-# SCRIPT_TYPE ACCOUNT #-} | |
3 | 3 | {-# CONTENT_TYPE DAPP #-} | |
4 | - | let | |
4 | + | let AI_TOKEN_ASSET_ID = base58'AxGKQRxKo4F2EbhrRq6N2tdLsxtMnpzQsS4QemV6V1W1' | |
5 | 5 | ||
6 | - | let | |
6 | + | let STATUS_OPEN = "open" | |
7 | 7 | ||
8 | - | let BAI_ASSET_ID = base58'AxGKQRxKo4F2EbhrRq6N2tdLsxtMnpzQsS4QemV6V1W1' | |
8 | + | let STATUS_CHECKED_OUT = "checked_out" | |
9 | + | ||
10 | + | let STATUS_DONE = "done" | |
11 | + | ||
12 | + | let CHECKED_OUT_BY = "_checked_out_by_" | |
13 | + | ||
14 | + | let SIMPLE_CHATGPT_TASK = "simple_ChatGPT_task" | |
15 | + | ||
16 | + | let CHECK_OUT_HEIGHT = "_check_out_height_" | |
17 | + | ||
18 | + | let REGISTER_HEIGHT = "_register_height_" | |
19 | + | ||
20 | + | let COMMIT_HEIGHT = "_commit_height_" | |
21 | + | ||
22 | + | func canBeCheckedOut (taskId,type) = { | |
23 | + | let status = getString(this, ((taskId + "_status_") + type)) | |
24 | + | (status == STATUS_OPEN) | |
25 | + | } | |
26 | + | ||
27 | + | ||
28 | + | func isCorrectAgent (taskId,agentId,type) = { | |
29 | + | let checkoutAgentId = getString(this, ((taskId + CHECKED_OUT_BY) + type)) | |
30 | + | (checkoutAgentId == agentId) | |
31 | + | } | |
32 | + | ||
33 | + | ||
34 | + | func getPriceForType (type) = match getInteger(this, ("price_" + type)) { | |
35 | + | case i: Int => | |
36 | + | i | |
37 | + | case _ => | |
38 | + | -1 | |
39 | + | } | |
40 | + | ||
9 | 41 | ||
10 | 42 | @Callable(i) | |
11 | - | func | |
43 | + | func registerTask (description,type) = { | |
12 | 44 | let numberOfPayments = size(i.payments) | |
13 | 45 | if ((numberOfPayments != 1)) | |
14 | 46 | then throw("Payment necessary!") | |
15 | 47 | else { | |
48 | + | let callerPublicKey = toBase58String(i.callerPublicKey) | |
49 | + | let txId = toBase58String(i.transactionId) | |
16 | 50 | let payment = i.payments[0] | |
17 | 51 | let fee = payment.amount | |
18 | 52 | let feeAssetId = payment.assetId | |
19 | - | let minFee = match getInteger(Address(fromBase58String(BAI_CONTRACT)), "price_fullchatgpt") { | |
53 | + | let taskId = ((txId + "_") + callerPublicKey) | |
54 | + | let timestamp = lastBlock.timestamp | |
55 | + | let minFee = getPriceForType(type) | |
56 | + | let daoUserValue = match getInteger(this, ("dao_user_" + callerPublicKey)) { | |
20 | 57 | case n: Int => | |
21 | - | n | |
58 | + | (n + fee) | |
22 | 59 | case _ => | |
23 | - | | |
60 | + | fee | |
24 | 61 | } | |
25 | - | if (if ((feeAssetId != BAI_ASSET_ID)) | |
26 | - | then true | |
27 | - | else (minFee > fee)) | |
28 | - | then throw("Payment of the minimal BAI amount necessary!") | |
29 | - | else { | |
30 | - | let publicKey = toBase58String(i.callerPublicKey) | |
31 | - | let timestamp = toString(lastBlock.timestamp) | |
32 | - | let result = invoke(Address(fromBase58String(BAI_CONTRACT)), "registerTaskCallback", [cid, "fullchatgpt", "callback"], [AttachedPayment(BAI_ASSET_ID, 10000000)]) | |
33 | - | if ((result == result)) | |
34 | - | then { | |
35 | - | let taskId = match result { | |
36 | - | case s: String => | |
37 | - | s | |
38 | - | case _ => | |
39 | - | throw("Unknown task id!") | |
40 | - | } | |
41 | - | [StringEntry((chatId + "_latest"), cid), StringEntry((chatId + "_status"), "waiting"), StringEntry(taskId, chatId), StringEntry(((publicKey + "_") + chatId), ((((cid + "_") + timestamp) + "_") + "waiting")), StringEntry((chatId + "_initiator"), publicKey)] | |
42 | - | } | |
43 | - | else throw("Strict value is not equal to itself.") | |
44 | - | } | |
62 | + | let daoSum = match getInteger(this, "dao_sum") { | |
63 | + | case n: Int => | |
64 | + | (n + fee) | |
65 | + | case _ => | |
66 | + | fee | |
67 | + | } | |
68 | + | if ((feeAssetId != AI_TOKEN_ASSET_ID)) | |
69 | + | then throw("Payment only possible in the AI Token!") | |
70 | + | else if ((minFee == -1)) | |
71 | + | then throw("Task type not supported!") | |
72 | + | else if ((minFee > fee)) | |
73 | + | then throw((("Payment needs to be at least " + toString(minFee)) + " BAI Token!")) | |
74 | + | else [StringEntry(((taskId + "_description_") + type), description), StringEntry(((txId + "_initializer_") + type), callerPublicKey), StringEntry(((taskId + "_status_") + type), STATUS_OPEN), StringEntry((taskId + "_type"), type), IntegerEntry(((taskId + REGISTER_HEIGHT) + type), height), IntegerEntry(((taskId + "_register_timestamp_") + type), timestamp), BooleanEntry(((("open_" + type) + "_") + taskId), true), IntegerEntry("dao_sum", daoSum), IntegerEntry(("dao_user_" + callerPublicKey), daoUserValue)] | |
45 | 75 | } | |
46 | 76 | } | |
47 | 77 | ||
48 | 78 | ||
49 | 79 | ||
50 | 80 | @Callable(i) | |
51 | - | func callback (taskId,cid) = if ((i.callerPublicKey != BAI_CONTRACT_PUBLIC_KEY)) | |
52 | - | then throw("Only BAI Contract is allowed to call the callback!") | |
53 | - | else { | |
54 | - | let chatId = match getString(taskId) { | |
55 | - | case s: String => | |
56 | - | s | |
57 | - | case _ => | |
58 | - | throw("Chat ID for task id not found!") | |
59 | - | } | |
60 | - | let publicKey = match getString((chatId + "_initiator")) { | |
61 | - | case s: String => | |
62 | - | s | |
63 | - | case _ => | |
64 | - | throw("No initiator found!") | |
65 | - | } | |
66 | - | let timestamp = toString(lastBlock.timestamp) | |
67 | - | [StringEntry((chatId + "_latest"), cid), StringEntry((chatId + "_status"), "done"), StringEntry(((publicKey + "_") + chatId), ((((cid + "_") + timestamp) + "_") + "done")), StringEntry("caller", toBase58String(i.callerPublicKey))] | |
68 | - | } | |
81 | + | func registerTaskCallback (description,type,callback) = { | |
82 | + | let numberOfPayments = size(i.payments) | |
83 | + | if ((numberOfPayments != 1)) | |
84 | + | then throw("Payment necessary!") | |
85 | + | else { | |
86 | + | let callerPublicKey = toBase58String(i.callerPublicKey) | |
87 | + | let caller = toString(i.caller) | |
88 | + | let txId = toBase58String(i.transactionId) | |
89 | + | let payment = i.payments[0] | |
90 | + | let fee = payment.amount | |
91 | + | let feeAssetId = payment.assetId | |
92 | + | let taskId = ((txId + "_") + callerPublicKey) | |
93 | + | let timestamp = lastBlock.timestamp | |
94 | + | let minFee = getPriceForType(type) | |
95 | + | if ((feeAssetId != AI_TOKEN_ASSET_ID)) | |
96 | + | then throw("Payment only possible in the AI Token!") | |
97 | + | else if ((minFee == -1)) | |
98 | + | then throw("Task type not supported!") | |
99 | + | else if ((minFee > fee)) | |
100 | + | then throw((("Payment needs to be at least " + toString(minFee)) + " BAI Token!")) | |
101 | + | else $Tuple2([StringEntry(((taskId + "_description_") + type), description), StringEntry(((txId + "_initializer_") + type), callerPublicKey), StringEntry(((taskId + "_callback_") + type), callback), StringEntry(((taskId + "_caller_") + type), caller), StringEntry(((taskId + "_status_") + type), STATUS_OPEN), StringEntry((taskId + "_type"), type), IntegerEntry(((taskId + REGISTER_HEIGHT) + type), height), IntegerEntry(((taskId + "_register_timestamp_") + type), timestamp), BooleanEntry(((("open_" + type) + "_") + taskId), true), StringEntry(((("callback_accounting_" + txId) + "_") + toString(height)), taskId)], taskId) | |
102 | + | } | |
103 | + | } | |
104 | + | ||
105 | + | ||
106 | + | ||
107 | + | @Callable(i) | |
108 | + | func checkoutTask (taskId,type) = { | |
109 | + | let callerPublicKey = toBase58String(i.callerPublicKey) | |
110 | + | let taskStillOpen = canBeCheckedOut(taskId, type) | |
111 | + | let timestamp = lastBlock.timestamp | |
112 | + | if (!(taskStillOpen)) | |
113 | + | then throw("Task not open for checkout!") | |
114 | + | else [StringEntry(((taskId + CHECKED_OUT_BY) + type), callerPublicKey), StringEntry(((taskId + "_status_") + type), STATUS_CHECKED_OUT), IntegerEntry(((taskId + CHECK_OUT_HEIGHT) + type), height), IntegerEntry(((taskId + "_check_out_timestamp_") + type), timestamp), BooleanEntry(((((("checked_out_by_" + callerPublicKey) + "_") + type) + "_") + taskId), true), DeleteEntry(((("open_" + type) + "_") + taskId))] | |
115 | + | } | |
116 | + | ||
117 | + | ||
118 | + | ||
119 | + | @Callable(i) | |
120 | + | func commitTask (taskId,response) = { | |
121 | + | let callerPublicKey = toBase58String(i.callerPublicKey) | |
122 | + | let type = match getString((taskId + "_type")) { | |
123 | + | case s: String => | |
124 | + | s | |
125 | + | case _ => | |
126 | + | "not set" | |
127 | + | } | |
128 | + | let correctAgent = isCorrectAgent(taskId, callerPublicKey, type) | |
129 | + | let timestamp = lastBlock.timestamp | |
130 | + | let callback = match getString(((taskId + "_callback_") + type)) { | |
131 | + | case s: String => | |
132 | + | s | |
133 | + | case _ => | |
134 | + | "no callback" | |
135 | + | } | |
136 | + | let caller = match getString(((taskId + "_caller_") + type)) { | |
137 | + | case s: String => | |
138 | + | s | |
139 | + | case _ => | |
140 | + | "no callback" | |
141 | + | } | |
142 | + | if (!(correctAgent)) | |
143 | + | then throw("Task may only be submitted by the agent who checked the task out!") | |
144 | + | else if ((type == "not set")) | |
145 | + | then throw("Can not identify type of task id") | |
146 | + | else if ((callback != "no callback")) | |
147 | + | then { | |
148 | + | let result = invoke(Address(fromBase58String(caller)), callback, [taskId, response], nil) | |
149 | + | if ((result == result)) | |
150 | + | then [StringEntry(((taskId + "_status_") + type), STATUS_DONE), StringEntry(((taskId + "_result_") + type), response), IntegerEntry(((taskId + COMMIT_HEIGHT) + type), height), IntegerEntry(((taskId + "_commit_timestamp_") + type), timestamp), DeleteEntry(((((("checked_out_by_" + callerPublicKey) + "_") + type) + "_") + taskId))] | |
151 | + | else throw("Strict value is not equal to itself.") | |
152 | + | } | |
153 | + | else [StringEntry(((taskId + "_status_") + type), STATUS_DONE), StringEntry(((taskId + "_result_") + type), response), IntegerEntry(((taskId + COMMIT_HEIGHT) + type), height), IntegerEntry(((taskId + "_commit_timestamp_") + type), timestamp), DeleteEntry(((((("checked_out_by_" + callerPublicKey) + "_") + type) + "_") + taskId))] | |
154 | + | } | |
69 | 155 | ||
70 | 156 | ||
71 | 157 | @Verifier(tx) |
Old | New | Differences | |
---|---|---|---|
1 | - | {-# STDLIB_VERSION | |
1 | + | {-# STDLIB_VERSION 6 #-} | |
2 | 2 | {-# SCRIPT_TYPE ACCOUNT #-} | |
3 | 3 | {-# CONTENT_TYPE DAPP #-} | |
4 | - | let | |
4 | + | let AI_TOKEN_ASSET_ID = base58'AxGKQRxKo4F2EbhrRq6N2tdLsxtMnpzQsS4QemV6V1W1' | |
5 | 5 | ||
6 | - | let | |
6 | + | let STATUS_OPEN = "open" | |
7 | 7 | ||
8 | - | let BAI_ASSET_ID = base58'AxGKQRxKo4F2EbhrRq6N2tdLsxtMnpzQsS4QemV6V1W1' | |
8 | + | let STATUS_CHECKED_OUT = "checked_out" | |
9 | + | ||
10 | + | let STATUS_DONE = "done" | |
11 | + | ||
12 | + | let CHECKED_OUT_BY = "_checked_out_by_" | |
13 | + | ||
14 | + | let SIMPLE_CHATGPT_TASK = "simple_ChatGPT_task" | |
15 | + | ||
16 | + | let CHECK_OUT_HEIGHT = "_check_out_height_" | |
17 | + | ||
18 | + | let REGISTER_HEIGHT = "_register_height_" | |
19 | + | ||
20 | + | let COMMIT_HEIGHT = "_commit_height_" | |
21 | + | ||
22 | + | func canBeCheckedOut (taskId,type) = { | |
23 | + | let status = getString(this, ((taskId + "_status_") + type)) | |
24 | + | (status == STATUS_OPEN) | |
25 | + | } | |
26 | + | ||
27 | + | ||
28 | + | func isCorrectAgent (taskId,agentId,type) = { | |
29 | + | let checkoutAgentId = getString(this, ((taskId + CHECKED_OUT_BY) + type)) | |
30 | + | (checkoutAgentId == agentId) | |
31 | + | } | |
32 | + | ||
33 | + | ||
34 | + | func getPriceForType (type) = match getInteger(this, ("price_" + type)) { | |
35 | + | case i: Int => | |
36 | + | i | |
37 | + | case _ => | |
38 | + | -1 | |
39 | + | } | |
40 | + | ||
9 | 41 | ||
10 | 42 | @Callable(i) | |
11 | - | func | |
43 | + | func registerTask (description,type) = { | |
12 | 44 | let numberOfPayments = size(i.payments) | |
13 | 45 | if ((numberOfPayments != 1)) | |
14 | 46 | then throw("Payment necessary!") | |
15 | 47 | else { | |
48 | + | let callerPublicKey = toBase58String(i.callerPublicKey) | |
49 | + | let txId = toBase58String(i.transactionId) | |
16 | 50 | let payment = i.payments[0] | |
17 | 51 | let fee = payment.amount | |
18 | 52 | let feeAssetId = payment.assetId | |
19 | - | let minFee = match getInteger(Address(fromBase58String(BAI_CONTRACT)), "price_fullchatgpt") { | |
53 | + | let taskId = ((txId + "_") + callerPublicKey) | |
54 | + | let timestamp = lastBlock.timestamp | |
55 | + | let minFee = getPriceForType(type) | |
56 | + | let daoUserValue = match getInteger(this, ("dao_user_" + callerPublicKey)) { | |
20 | 57 | case n: Int => | |
21 | - | n | |
58 | + | (n + fee) | |
22 | 59 | case _ => | |
23 | - | | |
60 | + | fee | |
24 | 61 | } | |
25 | - | if (if ((feeAssetId != BAI_ASSET_ID)) | |
26 | - | then true | |
27 | - | else (minFee > fee)) | |
28 | - | then throw("Payment of the minimal BAI amount necessary!") | |
29 | - | else { | |
30 | - | let publicKey = toBase58String(i.callerPublicKey) | |
31 | - | let timestamp = toString(lastBlock.timestamp) | |
32 | - | let result = invoke(Address(fromBase58String(BAI_CONTRACT)), "registerTaskCallback", [cid, "fullchatgpt", "callback"], [AttachedPayment(BAI_ASSET_ID, 10000000)]) | |
33 | - | if ((result == result)) | |
34 | - | then { | |
35 | - | let taskId = match result { | |
36 | - | case s: String => | |
37 | - | s | |
38 | - | case _ => | |
39 | - | throw("Unknown task id!") | |
40 | - | } | |
41 | - | [StringEntry((chatId + "_latest"), cid), StringEntry((chatId + "_status"), "waiting"), StringEntry(taskId, chatId), StringEntry(((publicKey + "_") + chatId), ((((cid + "_") + timestamp) + "_") + "waiting")), StringEntry((chatId + "_initiator"), publicKey)] | |
42 | - | } | |
43 | - | else throw("Strict value is not equal to itself.") | |
44 | - | } | |
62 | + | let daoSum = match getInteger(this, "dao_sum") { | |
63 | + | case n: Int => | |
64 | + | (n + fee) | |
65 | + | case _ => | |
66 | + | fee | |
67 | + | } | |
68 | + | if ((feeAssetId != AI_TOKEN_ASSET_ID)) | |
69 | + | then throw("Payment only possible in the AI Token!") | |
70 | + | else if ((minFee == -1)) | |
71 | + | then throw("Task type not supported!") | |
72 | + | else if ((minFee > fee)) | |
73 | + | then throw((("Payment needs to be at least " + toString(minFee)) + " BAI Token!")) | |
74 | + | else [StringEntry(((taskId + "_description_") + type), description), StringEntry(((txId + "_initializer_") + type), callerPublicKey), StringEntry(((taskId + "_status_") + type), STATUS_OPEN), StringEntry((taskId + "_type"), type), IntegerEntry(((taskId + REGISTER_HEIGHT) + type), height), IntegerEntry(((taskId + "_register_timestamp_") + type), timestamp), BooleanEntry(((("open_" + type) + "_") + taskId), true), IntegerEntry("dao_sum", daoSum), IntegerEntry(("dao_user_" + callerPublicKey), daoUserValue)] | |
45 | 75 | } | |
46 | 76 | } | |
47 | 77 | ||
48 | 78 | ||
49 | 79 | ||
50 | 80 | @Callable(i) | |
51 | - | func callback (taskId,cid) = if ((i.callerPublicKey != BAI_CONTRACT_PUBLIC_KEY)) | |
52 | - | then throw("Only BAI Contract is allowed to call the callback!") | |
53 | - | else { | |
54 | - | let chatId = match getString(taskId) { | |
55 | - | case s: String => | |
56 | - | s | |
57 | - | case _ => | |
58 | - | throw("Chat ID for task id not found!") | |
59 | - | } | |
60 | - | let publicKey = match getString((chatId + "_initiator")) { | |
61 | - | case s: String => | |
62 | - | s | |
63 | - | case _ => | |
64 | - | throw("No initiator found!") | |
65 | - | } | |
66 | - | let timestamp = toString(lastBlock.timestamp) | |
67 | - | [StringEntry((chatId + "_latest"), cid), StringEntry((chatId + "_status"), "done"), StringEntry(((publicKey + "_") + chatId), ((((cid + "_") + timestamp) + "_") + "done")), StringEntry("caller", toBase58String(i.callerPublicKey))] | |
68 | - | } | |
81 | + | func registerTaskCallback (description,type,callback) = { | |
82 | + | let numberOfPayments = size(i.payments) | |
83 | + | if ((numberOfPayments != 1)) | |
84 | + | then throw("Payment necessary!") | |
85 | + | else { | |
86 | + | let callerPublicKey = toBase58String(i.callerPublicKey) | |
87 | + | let caller = toString(i.caller) | |
88 | + | let txId = toBase58String(i.transactionId) | |
89 | + | let payment = i.payments[0] | |
90 | + | let fee = payment.amount | |
91 | + | let feeAssetId = payment.assetId | |
92 | + | let taskId = ((txId + "_") + callerPublicKey) | |
93 | + | let timestamp = lastBlock.timestamp | |
94 | + | let minFee = getPriceForType(type) | |
95 | + | if ((feeAssetId != AI_TOKEN_ASSET_ID)) | |
96 | + | then throw("Payment only possible in the AI Token!") | |
97 | + | else if ((minFee == -1)) | |
98 | + | then throw("Task type not supported!") | |
99 | + | else if ((minFee > fee)) | |
100 | + | then throw((("Payment needs to be at least " + toString(minFee)) + " BAI Token!")) | |
101 | + | else $Tuple2([StringEntry(((taskId + "_description_") + type), description), StringEntry(((txId + "_initializer_") + type), callerPublicKey), StringEntry(((taskId + "_callback_") + type), callback), StringEntry(((taskId + "_caller_") + type), caller), StringEntry(((taskId + "_status_") + type), STATUS_OPEN), StringEntry((taskId + "_type"), type), IntegerEntry(((taskId + REGISTER_HEIGHT) + type), height), IntegerEntry(((taskId + "_register_timestamp_") + type), timestamp), BooleanEntry(((("open_" + type) + "_") + taskId), true), StringEntry(((("callback_accounting_" + txId) + "_") + toString(height)), taskId)], taskId) | |
102 | + | } | |
103 | + | } | |
104 | + | ||
105 | + | ||
106 | + | ||
107 | + | @Callable(i) | |
108 | + | func checkoutTask (taskId,type) = { | |
109 | + | let callerPublicKey = toBase58String(i.callerPublicKey) | |
110 | + | let taskStillOpen = canBeCheckedOut(taskId, type) | |
111 | + | let timestamp = lastBlock.timestamp | |
112 | + | if (!(taskStillOpen)) | |
113 | + | then throw("Task not open for checkout!") | |
114 | + | else [StringEntry(((taskId + CHECKED_OUT_BY) + type), callerPublicKey), StringEntry(((taskId + "_status_") + type), STATUS_CHECKED_OUT), IntegerEntry(((taskId + CHECK_OUT_HEIGHT) + type), height), IntegerEntry(((taskId + "_check_out_timestamp_") + type), timestamp), BooleanEntry(((((("checked_out_by_" + callerPublicKey) + "_") + type) + "_") + taskId), true), DeleteEntry(((("open_" + type) + "_") + taskId))] | |
115 | + | } | |
116 | + | ||
117 | + | ||
118 | + | ||
119 | + | @Callable(i) | |
120 | + | func commitTask (taskId,response) = { | |
121 | + | let callerPublicKey = toBase58String(i.callerPublicKey) | |
122 | + | let type = match getString((taskId + "_type")) { | |
123 | + | case s: String => | |
124 | + | s | |
125 | + | case _ => | |
126 | + | "not set" | |
127 | + | } | |
128 | + | let correctAgent = isCorrectAgent(taskId, callerPublicKey, type) | |
129 | + | let timestamp = lastBlock.timestamp | |
130 | + | let callback = match getString(((taskId + "_callback_") + type)) { | |
131 | + | case s: String => | |
132 | + | s | |
133 | + | case _ => | |
134 | + | "no callback" | |
135 | + | } | |
136 | + | let caller = match getString(((taskId + "_caller_") + type)) { | |
137 | + | case s: String => | |
138 | + | s | |
139 | + | case _ => | |
140 | + | "no callback" | |
141 | + | } | |
142 | + | if (!(correctAgent)) | |
143 | + | then throw("Task may only be submitted by the agent who checked the task out!") | |
144 | + | else if ((type == "not set")) | |
145 | + | then throw("Can not identify type of task id") | |
146 | + | else if ((callback != "no callback")) | |
147 | + | then { | |
148 | + | let result = invoke(Address(fromBase58String(caller)), callback, [taskId, response], nil) | |
149 | + | if ((result == result)) | |
150 | + | then [StringEntry(((taskId + "_status_") + type), STATUS_DONE), StringEntry(((taskId + "_result_") + type), response), IntegerEntry(((taskId + COMMIT_HEIGHT) + type), height), IntegerEntry(((taskId + "_commit_timestamp_") + type), timestamp), DeleteEntry(((((("checked_out_by_" + callerPublicKey) + "_") + type) + "_") + taskId))] | |
151 | + | else throw("Strict value is not equal to itself.") | |
152 | + | } | |
153 | + | else [StringEntry(((taskId + "_status_") + type), STATUS_DONE), StringEntry(((taskId + "_result_") + type), response), IntegerEntry(((taskId + COMMIT_HEIGHT) + type), height), IntegerEntry(((taskId + "_commit_timestamp_") + type), timestamp), DeleteEntry(((((("checked_out_by_" + callerPublicKey) + "_") + type) + "_") + taskId))] | |
154 | + | } | |
69 | 155 | ||
70 | 156 | ||
71 | 157 | @Verifier(tx) | |
72 | 158 | func verify () = sigVerify(tx.bodyBytes, tx.proofs[0], tx.senderPublicKey) | |
73 | 159 |
github/deemru/w8io/026f985 27.85 ms ◑