[
"autonomous agent",
{
"init": "{\r
$_Registre = 'MGIC6DY2L6I4F5MEB3LSBGUCSTNLIJTV';\r
\r
// Retorna el valor d'una entrada del _Registre\r
$__dada = $refdada =>\r
data_feed [[\r
oracles = $_Registre,\r
feed_name = $refdada,\r
ifnone = 0\r
]];\r
\r
if ( $__dada( '_Portal' ) != trigger.address )\r
bounce( 'Accés interdit' );\r
\r
// Arguments, abreviacions, constants...\r
$args = trigger.data;\r
$adr__ = trigger.initial_address;\r
$id_unitat = trigger.output[[ asset != base ]].asset;\r
$qt = trigger.output[[ asset = $id_unitat ]];\r
\r
$ACC = $args.accio otherwise '';\r
$ref = $args.ref;\r
$nom = $args.nom;\r
$interficie = $args.interficie;\r
$promotora = $args.promotora;\r
$cicle_actual = $args.cicle_actual;\r
$_Calaix = $args._Calaix;\r
$id_estels = $args.Estels;\r
$dades = $args.dades otherwise {};\r
$provisio_registre = $args.provisio_registre;\r
$geto = $args.geto;\r
$estat_geto = $args.estat_geto;\r
$_FOP_accio = $args._FOP_accio;\r
\r
$acc = to_lower( $ACC );\r
$ref_ordinal_accio = 'ordinal_' || $acc || '_' || $geto;\r
$ref_accio = $acc || '_' || $geto || '_' || $adr__;\r
$ordinal_accio_actual =\r
$__dada( 'ordinal_' || $acc || '_' || $geto ) otherwise 0;\r
$ordinal_accio_incrementat = $ordinal_accio_actual + 1;\r
$nou_ordinal_accio = $acc || '_' || $geto || '_' || $ordinal_accio_incrementat;\r
$ref_data_accio = $nou_ordinal_accio || '_data';\r
$ref_cicle_accio = $nou_ordinal_accio || '_cicle';\r
$ref_qt_accio = $nou_ordinal_accio || '_qt';\r
\r
$ord_renovacio_adr__ = $__dada( 'renovacio_' || $geto || '_' || $adr__ );\r
$cicle_renovat_adr__ = $__dada( $ord_renovacio_adr__ || '_cicle' );\r
\r
$provisio = $id_unitat == 'none';\r
$args.sentit = 'entrada';\r
\r
// Funcions auxiliars\r
// Obté valor argument requesta especificat o rebota\r
$__arg = $arg =>\r
$args[ $arg ] otherwise\r
bounce( "Cal proporcionar el valor de: " || $arg );\r
\r
// Obté valor definidor del getó utilitzat\r
$__definidor = $refdef => {\r
$geto == 'Estels' ?\r
$__dada( $refdef ) :\r
$__dada( $geto || '_' || to_lower( $refdef ) )\r
};\r
\r
// Comprova si adreça activada per operar amb getó especificat\r
$__activada = ( $refgeto, $adre ) =>\r
!! $__dada( 'activacio_' || $refgeto || '_' || $adre ) ?\r
true :\r
bounce( 'Adreça no activada per a ' || $refgeto );\r
\r
// Comprova si qt proporcionada cobreix import especificat\r
$__qtSuficient = $refimport, $q => {\r
$import_requerit = $__definidor( $refimport );\r
$import_requerit > $q ?\r
bounce( "L'import requerit és de " || $import_requerit )\r
: true\r
};\r
\r
// Comprova si adreça consta com a subscrita\r
$__subscrita = $adr =>\r
!! $__dada( 'subscripcio_' || $geto || '_' || $adr ) ?\r
true :\r
bounce( "Adreça no subscrita" );\r
\r
// Consulta si acció permesa\r
$__accPermesa = $ac => {\r
$geto == 'Estels' ?\r
true :\r
$__dada( $geto || '_' || to_lower( $ac ) || 'ns_permeses' ) == 1\r
};\r
\r
// Consulta si acció restringida\r
$__accRestringida = $ac => {\r
$geto == 'Estels' ?\r
false :\r
$__dada( $geto || '_' || to_lower( $ac ) || 'ns_restringides' ) == 1\r
};\r
\r
// Si acció restringida per al getó, comprova si adreça capacitada\r
$__capacitada = ( $ac, $ad ) => {\r
$capacitacio = $__dada( $geto || '_' || $ac || '_' || $ad );\r
$__accRestringida( $ac ) AND ! $capacitacio ?\r
bounce( 'Acció restringida i adreça no capacitada' ) :\r
true\r
};\r
\r
// Nou total a registrar\r
$__nou_total = ( $ref_tot, $increment ) => {\r
$nou_total = $__dada( 'total_' || $ref_tot ) otherwise 0;\r
$dades[ 'total_' || $ref_tot ] = $nou_total + $increment;\r
};\r
\r
// Incrementa sumatoris d'entrades compensables\r
$__increment_sumatoris_compensables = $increment => {\r
$__nou_total( 'compensables_' || $geto || '_via_' || $interficie, $increment );\r
$__nou_total( 'compensables_' || $geto || '_per_' || $promotora, $increment );\r
};\r
\r
// Escala actual\r
$volum_escala = $__dada( 'volum_escala_' || $geto );\r
$nombre_digits = length( $volum_escala ) otherwise 1;\r
$escala_actual = $__dada( 'escala_actual_' || $geto ) otherwise 1;\r
$data_escala_actual = $__dada( 'data_escala_actual_' || $geto );\r
\r
if ( $nombre_digits > $escala_actual ) {\r
$nova_escala = $nombre_digits;\r
$data_nova_escala = timestamp;\r
$interval_escala = 1000;\r
} else $interval_escala = timestamp - $data_escala_actual + 1000;\r
\r
\r
// ...\r
$registre = {};\r
$dades[ 'escala_actual_' || $geto ] = $nova_escala otherwise $escala_actual;\r
$dades[ $ref_ordinal_accio ] = $ordinal_accio_incrementat;\r
$dades[ $ref_accio ] = $nou_ordinal_accio;\r
$dades[ $ref_data_accio ] = timestamp;\r
$dades[ $ref_cicle_accio ] = $cicle_actual;\r
}",
"messages": {
"cases": [
{
"if": "{ $ACC == 'Activacio' AND ! $provisio }",
"init": "{\r
if ( !! $__dada( $ref_accio ) )\r
bounce( 'Aquesta adreça ja consta com a activada' );\r
\r
$condicions =\r
$__qtSuficient( 'Import_Activacio', $qt )\r
AND $__capacitada( 'Activacio', $adr__ );\r
\r
$dades[ $ref_qt_accio ] = $qt;\r
$dades[ $nou_ordinal_accio || '_nom' ] = $nom;\r
$dades[ $nou_ordinal_accio || '_escala' ] = $escala_actual;\r
$dades[ $nou_ordinal_accio || '_interval' ] = $interval_escala;\r
$__nou_total( 'activacions_' || $geto, $qt );\r
$__increment_sumatoris_compensables( $qt );\r
$dades[ 'volum_escala_' || $geto ] = $volum_escala + $qt;\r
\r
$registre.dades = $dades;\r
\r
$args.prova = 'prova';\r
}",
"messages": [
{
"app": "data",
"payload": "{ $registre || $args }"
},
{
"app": "payment",
"payload": {
"asset": "base",
"outputs": [
{
"address": "{ $_Registre }",
"amount": "{ $provisio_registre }"
}
]
}
},
{
"app": "payment",
"payload": {
"asset": "{ $id_unitat }",
"outputs": [
{
"address": "{ $_FOP_accio }",
"amount": "{ $qt }"
}
]
}
},
{
"app": "state",
"state": "{\r
response[ 'Nom' ] = $nom;\r
response[ 'Adreça' ] = $adr__;\r
response[ 'Getó' ] = $geto;\r
}"
}
]
},
{
"if": "{ $ACC == 'Subscripcio' AND ! $provisio }",
"init": "{\r
if ( !! $__dada( $ref_accio ) )\r
bounce( 'Aquesta adreça ja consta com a subscrita' );\r
\r
$condicions =\r
$__qtSuficient( 'Import_Subscripcio', $qt )\r
AND $__capacitada( 'Subscripcio', $adr__ );\r
//AND $__arg( 'nom' )\r
//AND $__arg( 'aportacio' );\r
\r
$dades[ $nou_ordinal_accio || '_nom' ] = $nom;\r
$dades[ $nou_ordinal_accio || '_aportacio' ] = $args.aportacio;\r
\r
$ordinal_renovacio_actual =\r
$__dada( 'ordinal_renovacio_' || $geto ) otherwise 0;\r
$nou_ordinal_renovacio = $ordinal_renovacio_actual + 1;\r
$ord_renovacio = 'renovacio_' || $nou_ordinal_renovacio;\r
$ref_renovacio = 'renovacio_' || $geto || '_' || $adr__;\r
\r
$dades[ $ref_renovacio ] = $ord_renovacio;\r
$dades[ $ord_renovacio || '_data' ] = timestamp;\r
$dades[ $ord_renovacio || '_cicle' ] = $cicle_actual;\r
$dades[ 'ordinal_renovacio_' || $geto ] = $nou_ordinal_renovacio;\r
\r
$__nou_total( 'subscripcions_' || $geto, $qt );\r
$__increment_sumatoris_compensables( $qt );\r
$dades[ 'volum_escala_' || $geto ] = $volum_escala + $qt;\r
\r
$registre.dades = $dades;\r
}",
"messages": [
{
"app": "data",
"payload": "{ $registre || $args }"
},
{
"app": "payment",
"payload": {
"asset": "base",
"outputs": [
{
"address": "{ $_Registre }",
"amount": "{ $provisio_registre }"
}
]
}
},
{
"app": "payment",
"payload": {
"asset": "{ $id_unitat }",
"outputs": [
{
"address": "{ $_FOP_accio }",
"amount": "{ $qt }"
}
]
}
},
{
"app": "state",
"state": "{\r
response[ 'Nom' ] = $nom;\r
response[ 'Adreça' ] = $adr__;\r
response[ 'Getó' ] = $geto;\r
}"
}
]
},
{
"if": "{ $ACC == 'Renovacio' AND ! $provisio }",
"init": "{\r
$condicions =\r
$__subscrita( $adr__ )\r
AND $__qtSuficient( 'Import_Renovacio', $qt )\r
AND $__capacitada( 'Subscripcio', $adr__ );\r
\r
if ( $cicle_actual == $cicle_renovat_adr__ )\r
bounce( 'El cicle actual ja consta com a renovat' );\r
\r
$__nou_total( 'renovacions_' || $geto, $qt );\r
$__increment_sumatoris_compensables( $qt );\r
$dades[ 'volum_escala_' || $geto ] = $volum_escala + $qt;\r
\r
$registre.dades = $dades;\r
}",
"messages": [
{
"app": "data",
"payload": "{ $registre || $args }"
},
{
"app": "payment",
"payload": {
"asset": "base",
"outputs": [
{
"address": "{ $_Registre }",
"amount": "{ $provisio_registre }"
}
]
}
},
{
"app": "payment",
"payload": {
"asset": "{ $id_unitat }",
"outputs": [
{
"address": "{ $_FOP_accio }",
"amount": "{ $qt }"
}
]
}
},
{
"app": "state",
"state": "{\r
response[ 'Cicle renovat' ] = $cicle_actual;\r
response[ 'Getó' ] = $geto;\r
}"
}
]
},
{
"if": "{ $ACC == 'Diposit' AND ! $provisio }",
"init": "{\r
$condicions =\r
$__subscrita( $adr__ )\r
AND $__capacitada( 'Conversio', $adr__ )\r
AND $__capacitada( 'Subscripcio', $adr__ );\r
\r
$diposit_minim = $__definidor( 'Diposit_Minim' );\r
if ( $qt < $diposit_minim )\r
bounce( 'El dipòsit mínim és de ' || $diposit_minim );\r
\r
if ( $cicle_renovat_adr__ < $cicle_actual )\r
bounce( 'Subscripció no renovada. Darrer cicle renovat: ' ||\r
$cicle_renovat_adr__ || ' Cicle actual: ' || $cicle_actual );\r
\r
$taxa_conversio = $__definidor( 'Taxa_Conversio' );\r
$cicles_diposit = $__definidor( 'Cicles_Diposit' );\r
$factor_conversio = $__definidor( 'factor_conversio' ) otherwise 1;\r
$cicle_conversio = $cicle_actual + $cicles_diposit;\r
$taxa = round( $qt * $factor_conversio * $taxa_conversio / 100, 0 );\r
$qt_conversio = $qt - $taxa;\r
$dades[ $ref_qt_accio ] = $qt;\r
$dades[ $nou_ordinal_accio || '_dipositant' ] = $adr__;\r
$dades[ $nou_ordinal_accio || '_geto_diposit' ] = $geto;\r
$dades[ $nou_ordinal_accio || '_taxa' ] = $taxa;\r
$dades[ $nou_ordinal_accio || '_qt_conversio' ] = $qt_conversio;\r
$dades[ $nou_ordinal_accio || '_cicle_conversio' ] = $cicle_conversio;\r
$__nou_total( 'diposits_' || $geto, $qt );\r
\r
$registre.dades = $dades;\r
}",
"messages": [
{
"app": "data",
"payload": "{ $registre || $args }"
},
{
"app": "payment",
"payload": {
"asset": "base",
"outputs": [
{
"address": "{ $_Registre }",
"amount": "{ $provisio_registre }"
}
]
}
},
{
"app": "payment",
"payload": {
"asset": "{ $id_unitat }",
"outputs": [
{
"address": "{ $_Calaix }",
"amount": "{ $qt }"
}
]
}
},
{
"app": "state",
"state": "{\r
response[ $nou_ordinal_accio ] = $ref_accio;\r
response[ 'Qt dipòsit' ] = $qt;\r
response[ 'Qt conversió' ] = $qt_conversio;\r
response[ 'Cicle conversió' ] = $cicle_conversio;\r
}"
}
]
},
{
"if": "{ $ACC == 'Contribucio' AND ! $provisio }",
"init": "{\r
$contribucions_permeses =\r
$__accPermesa ( 'Contribucio' ) otherwise\r
bounce( 'Acció no permesa amb aquest geto' );\r
\r
$dades[ $ref_qt_accio ] = $qt;\r
$dades[ $nou_ordinal_accio || '_contribuidora' ] = $adr__;\r
$dades[ $nou_ordinal_accio || '_geto' ] = $geto;\r
$dades[ $nou_ordinal_accio || '_escala' ] = $escala_actual;\r
$dades[ $nou_ordinal_accio || '_interval' ] = $interval_escala;\r
$__nou_total( 'contribucions_' || $geto , $qt );\r
$__increment_sumatoris_compensables( $qt );\r
$dades[ 'volum_escala_' || $geto ] = $volum_escala + $qt;\r
\r
$registre.dades = $dades;\r
}",
"messages": [
{
"app": "data",
"payload": "{ $registre || $args }"
},
{
"app": "payment",
"payload": {
"asset": "base",
"outputs": [
{
"address": "{ $_Registre }",
"amount": "{ $provisio_registre }"
}
]
}
},
{
"app": "payment",
"payload": {
"asset": "{ $id_unitat }",
"outputs": [
{
"address": "{ $_FOP_accio }",
"amount": "{ $qt }"
}
]
}
},
{
"app": "state",
"state": "{\r
response[ $nou_ordinal_accio ] = $ref_accio;\r
response[ 'Contribuïdora' ] = $adr__;\r
response[ 'Quantitat' ] = $qt;\r
}"
}
]
},
{
"if": "{ $ACC == 'Transfer' AND ! $provisio }",
"init": "{\r
$receptora = $__arg( 'receptora' );\r
$condicions =\r
$__activada( 'Estels', $receptora )\r
AND $__activada( $geto, $receptora )\r
AND $__capacitada( 'Recepcio', $receptora );\r
\r
$ref_subscripcio = 'subscripcio_' || $geto || '_' || $receptora;\r
$ord_subscripcio = $__dada( $ref_subscripcio );\r
$ref_renovacio = 'renovacio_' || $geto || '_' || $receptora;\r
$ord_renovacio = $__dada( $ref_renovacio );\r
$cicle_renovacio = $__dada( $ord_renovacio || '_cicle' ) otherwise 0;\r
$receptora_renovada = $cicle_renovacio == $cicle_actual;\r
\r
$__nou_total( 'transfers_' || $geto, $qt );\r
\r
$args.qt_transfer = $qt;\r
\r
if ( !! $ord_subscripcio AND $receptora_renovada ) {\r
$percent_aportacio = $__dada( $ord_subscripcio || '_aportacio' );\r
$qt_aportacio = floor( $qt * $percent_aportacio / 100 );\r
$__nou_total( 'aportacions_' || $geto, $qt_aportacio );\r
$__nou_total( 'aportacions_' || $geto || '_' || $receptora, $qt_aportacio );\r
$__increment_sumatoris_compensables( $qt_aportacio );\r
$dades[ 'volum_escala_' || $geto ] = $volum_escala + $qt_aportacio;\r
\r
$args.qt_transfer = $qt - $qt_aportacio;\r
$args.emissora = $receptora;\r
}\r
\r
$registre.dades = $dades;\r
}",
"messages": [
{
"app": "data",
"payload": "{ $registre || $args }"
},
{
"app": "payment",
"payload": {
"asset": "base",
"outputs": [
{
"address": "{ $_Registre }",
"amount": "{ $provisio_registre }"
}
]
}
},
{
"if": "{ !! $qt_aportacio }",
"app": "payment",
"payload": {
"asset": "{ $id_unitat }",
"outputs": [
{
"address": "{ $_FOP_accio }",
"amount": "{ $qt_aportacio }"
},
{
"address": "{ $receptora }",
"amount": "{ $args.qt_transfer }"
}
]
}
},
{
"if": "{ ! $qt_aportacio }",
"app": "payment",
"payload": {
"asset": "{ $id_unitat }",
"outputs": [
{
"address": "{ $receptora }",
"amount": "{ $args.qt_transfer }"
}
]
}
},
{
"app": "state",
"state": "{\r
if ( !! $qt_aportacio )\r
response[ 'Receptora aporta en '|| $geto ] = $qt_aportacio;\r
}"
}
]
},
{
"if": "{ $ACC == 'Conversio' AND ! $provisio }",
"init": "{\r
$qt_dipositada = $__dada( $ref || '_qt' );\r
\r
if ( ! $qt_dipositada )\r
bounce( 'Dipòsit desconegut' );\r
\r
$qt_conversio = $__dada( $ref || '_qt_conversio' );\r
$geto_diposit = $__dada( $ref || '_geto_diposit' );\r
$cicle_conversio = $__dada( $ref || '_cicle_conversio' );\r
$ord_renovacio = $__dada( 'renovacio_' || $geto_diposit || '_' || $adr__ );\r
$cicle_renovat = $__dada( $ord_renovacio || '_cicle' );\r
$id_unitat_conversio = $geto_diposit == 'Estels' ? 'base' : $id_estels;\r
$unitat_conversio = $geto_diposit == 'Estels' ? 'Bytes' : 'Estels';\r
$ref_conversio = 'conversio_' || $ref;\r
\r
if ( $adr__ != $__dada( $ref || '_dipositant' ))\r
bounce( "L'adreça receptora ha de ser la dipositant" );\r
\r
if ( !! $__dada( $ref_conversio ))\r
bounce( 'Aquest dipòsit ja ha estat convertit' );\r
\r
if ( $cicle_conversio > $cicle_actual )\r
bounce( "Encara no és l'hora" );\r
\r
if ( $cicle_renovat < $cicle_actual )\r
bounce( "No renovada en per al cicle actual" );\r
\r
$dades[ $ref_qt_accio ] = $qt_conversio;\r
$dades[ $nou_ordinal_accio || '_unitat' ] = $unitat_conversio;\r
$dades[ $nou_ordinal_accio || '_rebedora' ] = $adr__;\r
$__nou_total( 'conversions_' || $unitat_conversio, $qt_conversio );\r
$__nou_total( 'taxes_' || $geto_diposit, ( $qt_dipositada - $qt_conversio ));\r
\r
$args.qt = $qt_conversio;\r
$args.rebedora = $adr__;\r
$args.sentit = 'sortida';\r
$args.id_unitat_sortida = $id_unitat_conversio;\r
$args.unitat_sortida = $unitat_conversio;\r
\r
$registre.dades = $dades;\r
}",
"messages": [
{
"app": "data",
"payload": "{ $registre || $args }"
},
{
"app": "payment",
"payload": {
"asset": "base",
"outputs": [
{
"address": "{ $_Registre }",
"amount": "{ $provisio_registre }"
}
]
}
},
{
"app": "payment",
"payload": {
"asset": "{ $id_unitat }",
"outputs": [
{
"address": "{ $_Calaix }",
"amount": "{ $qt }"
}
]
}
}
]
},
{
"if": "{ ( $ACC == 'Bonificacio' OR $ACC == 'Retribucio' ) AND ! $provisio }",
"init": "{\r
\r
if ( $ACC == 'Bonificacio' ) {\r
$bonificacio_permesa =\r
$__accPermesa ( 'Bonificacio' ) otherwise\r
bounce( 'Acció de bonificació no permesa en aquest geto' );\r
\r
$ord_activac = $__dada( 'activacio_' || $geto || '_' || $adr__ );\r
$import = $__dada( $ord_activac || '_qt' );\r
$escala = $__dada( $ord_activac || '_escala' );\r
$interval = $__dada( $ord_activac || '_interval' );\r
$ref_acc =\r
'bonificacio_' || $escala_actual || '_' || $geto || '_' || $adr__;\r
}\r
\r
if ( $ACC == 'Retribucio' ) {\r
$import = $__dada( $ref || '_qt' )\r
otherwise bounce( 'Contribució desconeguda' );\r
\r
if ( ! $__accPermesa ( 'Contribucio' ) )\r
bounce( 'Acció de contribució no permesa en aquest geto' );\r
\r
$geto_contribucio = $__dada( $ref || '_geto' );\r
$escala = $__dada( $ref || '_escala' );\r
$interval = $__dada( $ref || '_interval' );\r
\r
if ( $geto_contribucio != $geto )\r
bounce( "El getó utilitzat i el de la contribució han de ser el mateix" );\r
\r
if ( $adr__ != $__dada( $ref || '_contribuidora' ))\r
bounce( "Només l'adreça contribuïdora pot rebre la retribució" );\r
\r
$ref_acc = 'retribucio_' || $ref || '_escala_' || $escala_actual;\r
}\r
\r
// La retribució és pendent\r
if ( !! $__dada( $ref_acc ))\r
bounce( "Ja ha estat retribuïda per a l'escala actual" );\r
\r
// Cal que s'hagi produït un salt d'escala\r
if ( $escala_actual == $escala )\r
bounce( "Cal que es produeixi un salt d'escala" );\r
\r
/* Comentat temporalment per a facilitar els tests !!\r
\r
// Cal que hagi passat igual o més temps entre la data del salt d'escala i la de la\r
//retribució que entre la data del salt d'escala de la contribucio i la data d'aquesta\r
\r
$diferencia_intervals = $interval_escala - $interval;\r
if ( $diferencia_intervals < 0 )\r
bounce( "Encara no és l'hora" );\r
*/\r
\r
// Determina la qt de la retribució\r
$qt_acc = $import * ( $escala_actual - $escala );\r
\r
//...\r
delete( $dades, $ref_accio );\r
$dades[ $ref_acc ] = $nou_ordinal_accio;\r
$dades[ $nou_ordinal_accio || '_rebedora' ] = $adr__;\r
$dades[ $ref_qt_accio ] = $qt_acc;\r
$dades[ $nou_ordinal_accio || '_geto' ] = $geto;\r
$__nou_total( $acc || 'ns_' || $geto, $qt_acc );\r
\r
$args.qt = $qt_acc;\r
$args.rebedora = $adr__;\r
$args.sentit = 'sortida';\r
$args.id_unitat_sortida = $id_unitat;\r
$args.unitat_sortida = $geto;\r
\r
$registre.dades = $dades;\r
}",
"messages": [
{
"app": "data",
"payload": "{ $registre || $args }"
},
{
"app": "payment",
"payload": {
"asset": "base",
"outputs": [
{
"address": "{ $_Registre }",
"amount": "{ $provisio_registre }"
}
]
}
},
{
"app": "payment",
"payload": {
"asset": "{ $id_unitat }",
"outputs": [
{
"address": "{ $_FOP_accio }",
"amount": "{ $qt }"
}
]
}
}
]
}
]
}
}
]