This commit is contained in:
julian 2023-01-10 11:51:38 -06:00
parent fedb91f11c
commit 279d7f37bd
3 changed files with 112 additions and 112 deletions

View file

@ -16,7 +16,7 @@ class Transaction {
late int timestamp; late int timestamp;
@enumerated @enumerated
late TransactionType txType; late TransactionType type;
@enumerated @enumerated
late TransactionSubType subType; late TransactionSubType subType;
@ -61,6 +61,7 @@ enum TransactionType {
outgoing, outgoing,
incoming, incoming,
sendToSelf, // should we keep this? sendToSelf, // should we keep this?
unknown,
anonymize; // firo specific anonymize; // firo specific
} }

View file

@ -63,16 +63,16 @@ const TransactionSchema = CollectionSchema(
name: r'timestamp', name: r'timestamp',
type: IsarType.long, type: IsarType.long,
), ),
r'txType': PropertySchema(
id: 9,
name: r'txType',
type: IsarType.byte,
enumMap: _TransactiontxTypeEnumValueMap,
),
r'txid': PropertySchema( r'txid': PropertySchema(
id: 10, id: 9,
name: r'txid', name: r'txid',
type: IsarType.string, type: IsarType.string,
),
r'type': PropertySchema(
id: 10,
name: r'type',
type: IsarType.byte,
enumMap: _TransactiontypeEnumValueMap,
) )
}, },
estimateSize: _transactionEstimateSize, estimateSize: _transactionEstimateSize,
@ -146,8 +146,8 @@ void _transactionSerialize(
writer.writeString(offsets[6], object.slateId); writer.writeString(offsets[6], object.slateId);
writer.writeByte(offsets[7], object.subType.index); writer.writeByte(offsets[7], object.subType.index);
writer.writeLong(offsets[8], object.timestamp); writer.writeLong(offsets[8], object.timestamp);
writer.writeByte(offsets[9], object.txType.index); writer.writeString(offsets[9], object.txid);
writer.writeString(offsets[10], object.txid); writer.writeByte(offsets[10], object.type.index);
} }
Transaction _transactionDeserialize( Transaction _transactionDeserialize(
@ -169,10 +169,10 @@ Transaction _transactionDeserialize(
_TransactionsubTypeValueEnumMap[reader.readByteOrNull(offsets[7])] ?? _TransactionsubTypeValueEnumMap[reader.readByteOrNull(offsets[7])] ??
TransactionSubType.none; TransactionSubType.none;
object.timestamp = reader.readLong(offsets[8]); object.timestamp = reader.readLong(offsets[8]);
object.txType = object.txid = reader.readString(offsets[9]);
_TransactiontxTypeValueEnumMap[reader.readByteOrNull(offsets[9])] ?? object.type =
_TransactiontypeValueEnumMap[reader.readByteOrNull(offsets[10])] ??
TransactionType.outgoing; TransactionType.outgoing;
object.txid = reader.readString(offsets[10]);
return object; return object;
} }
@ -203,10 +203,10 @@ P _transactionDeserializeProp<P>(
case 8: case 8:
return (reader.readLong(offset)) as P; return (reader.readLong(offset)) as P;
case 9: case 9:
return (_TransactiontxTypeValueEnumMap[reader.readByteOrNull(offset)] ??
TransactionType.outgoing) as P;
case 10:
return (reader.readString(offset)) as P; return (reader.readString(offset)) as P;
case 10:
return (_TransactiontypeValueEnumMap[reader.readByteOrNull(offset)] ??
TransactionType.outgoing) as P;
default: default:
throw IsarError('Unknown property with id $propertyId'); throw IsarError('Unknown property with id $propertyId');
} }
@ -222,17 +222,19 @@ const _TransactionsubTypeValueEnumMap = {
1: TransactionSubType.bip47Notification, 1: TransactionSubType.bip47Notification,
2: TransactionSubType.mint, 2: TransactionSubType.mint,
}; };
const _TransactiontxTypeEnumValueMap = { const _TransactiontypeEnumValueMap = {
'outgoing': 0, 'outgoing': 0,
'incoming': 1, 'incoming': 1,
'sendToSelf': 2, 'sendToSelf': 2,
'anonymize': 3, 'unknown': 3,
'anonymize': 4,
}; };
const _TransactiontxTypeValueEnumMap = { const _TransactiontypeValueEnumMap = {
0: TransactionType.outgoing, 0: TransactionType.outgoing,
1: TransactionType.incoming, 1: TransactionType.incoming,
2: TransactionType.sendToSelf, 2: TransactionType.sendToSelf,
3: TransactionType.anonymize, 3: TransactionType.unknown,
4: TransactionType.anonymize,
}; };
Id _transactionGetId(Transaction object) { Id _transactionGetId(Transaction object) {
@ -1105,60 +1107,6 @@ extension TransactionQueryFilter
}); });
} }
QueryBuilder<Transaction, Transaction, QAfterFilterCondition> txTypeEqualTo(
TransactionType value) {
return QueryBuilder.apply(this, (query) {
return query.addFilterCondition(FilterCondition.equalTo(
property: r'txType',
value: value,
));
});
}
QueryBuilder<Transaction, Transaction, QAfterFilterCondition>
txTypeGreaterThan(
TransactionType value, {
bool include = false,
}) {
return QueryBuilder.apply(this, (query) {
return query.addFilterCondition(FilterCondition.greaterThan(
include: include,
property: r'txType',
value: value,
));
});
}
QueryBuilder<Transaction, Transaction, QAfterFilterCondition> txTypeLessThan(
TransactionType value, {
bool include = false,
}) {
return QueryBuilder.apply(this, (query) {
return query.addFilterCondition(FilterCondition.lessThan(
include: include,
property: r'txType',
value: value,
));
});
}
QueryBuilder<Transaction, Transaction, QAfterFilterCondition> txTypeBetween(
TransactionType lower,
TransactionType upper, {
bool includeLower = true,
bool includeUpper = true,
}) {
return QueryBuilder.apply(this, (query) {
return query.addFilterCondition(FilterCondition.between(
property: r'txType',
lower: lower,
includeLower: includeLower,
upper: upper,
includeUpper: includeUpper,
));
});
}
QueryBuilder<Transaction, Transaction, QAfterFilterCondition> txidEqualTo( QueryBuilder<Transaction, Transaction, QAfterFilterCondition> txidEqualTo(
String value, { String value, {
bool caseSensitive = true, bool caseSensitive = true,
@ -1289,6 +1237,59 @@ extension TransactionQueryFilter
)); ));
}); });
} }
QueryBuilder<Transaction, Transaction, QAfterFilterCondition> typeEqualTo(
TransactionType value) {
return QueryBuilder.apply(this, (query) {
return query.addFilterCondition(FilterCondition.equalTo(
property: r'type',
value: value,
));
});
}
QueryBuilder<Transaction, Transaction, QAfterFilterCondition> typeGreaterThan(
TransactionType value, {
bool include = false,
}) {
return QueryBuilder.apply(this, (query) {
return query.addFilterCondition(FilterCondition.greaterThan(
include: include,
property: r'type',
value: value,
));
});
}
QueryBuilder<Transaction, Transaction, QAfterFilterCondition> typeLessThan(
TransactionType value, {
bool include = false,
}) {
return QueryBuilder.apply(this, (query) {
return query.addFilterCondition(FilterCondition.lessThan(
include: include,
property: r'type',
value: value,
));
});
}
QueryBuilder<Transaction, Transaction, QAfterFilterCondition> typeBetween(
TransactionType lower,
TransactionType upper, {
bool includeLower = true,
bool includeUpper = true,
}) {
return QueryBuilder.apply(this, (query) {
return query.addFilterCondition(FilterCondition.between(
property: r'type',
lower: lower,
includeLower: includeLower,
upper: upper,
includeUpper: includeUpper,
));
});
}
} }
extension TransactionQueryObject extension TransactionQueryObject
@ -1542,18 +1543,6 @@ extension TransactionQuerySortBy
}); });
} }
QueryBuilder<Transaction, Transaction, QAfterSortBy> sortByTxType() {
return QueryBuilder.apply(this, (query) {
return query.addSortBy(r'txType', Sort.asc);
});
}
QueryBuilder<Transaction, Transaction, QAfterSortBy> sortByTxTypeDesc() {
return QueryBuilder.apply(this, (query) {
return query.addSortBy(r'txType', Sort.desc);
});
}
QueryBuilder<Transaction, Transaction, QAfterSortBy> sortByTxid() { QueryBuilder<Transaction, Transaction, QAfterSortBy> sortByTxid() {
return QueryBuilder.apply(this, (query) { return QueryBuilder.apply(this, (query) {
return query.addSortBy(r'txid', Sort.asc); return query.addSortBy(r'txid', Sort.asc);
@ -1565,6 +1554,18 @@ extension TransactionQuerySortBy
return query.addSortBy(r'txid', Sort.desc); return query.addSortBy(r'txid', Sort.desc);
}); });
} }
QueryBuilder<Transaction, Transaction, QAfterSortBy> sortByType() {
return QueryBuilder.apply(this, (query) {
return query.addSortBy(r'type', Sort.asc);
});
}
QueryBuilder<Transaction, Transaction, QAfterSortBy> sortByTypeDesc() {
return QueryBuilder.apply(this, (query) {
return query.addSortBy(r'type', Sort.desc);
});
}
} }
extension TransactionQuerySortThenBy extension TransactionQuerySortThenBy
@ -1689,18 +1690,6 @@ extension TransactionQuerySortThenBy
}); });
} }
QueryBuilder<Transaction, Transaction, QAfterSortBy> thenByTxType() {
return QueryBuilder.apply(this, (query) {
return query.addSortBy(r'txType', Sort.asc);
});
}
QueryBuilder<Transaction, Transaction, QAfterSortBy> thenByTxTypeDesc() {
return QueryBuilder.apply(this, (query) {
return query.addSortBy(r'txType', Sort.desc);
});
}
QueryBuilder<Transaction, Transaction, QAfterSortBy> thenByTxid() { QueryBuilder<Transaction, Transaction, QAfterSortBy> thenByTxid() {
return QueryBuilder.apply(this, (query) { return QueryBuilder.apply(this, (query) {
return query.addSortBy(r'txid', Sort.asc); return query.addSortBy(r'txid', Sort.asc);
@ -1712,6 +1701,18 @@ extension TransactionQuerySortThenBy
return query.addSortBy(r'txid', Sort.desc); return query.addSortBy(r'txid', Sort.desc);
}); });
} }
QueryBuilder<Transaction, Transaction, QAfterSortBy> thenByType() {
return QueryBuilder.apply(this, (query) {
return query.addSortBy(r'type', Sort.asc);
});
}
QueryBuilder<Transaction, Transaction, QAfterSortBy> thenByTypeDesc() {
return QueryBuilder.apply(this, (query) {
return query.addSortBy(r'type', Sort.desc);
});
}
} }
extension TransactionQueryWhereDistinct extension TransactionQueryWhereDistinct
@ -1773,18 +1774,18 @@ extension TransactionQueryWhereDistinct
}); });
} }
QueryBuilder<Transaction, Transaction, QDistinct> distinctByTxType() {
return QueryBuilder.apply(this, (query) {
return query.addDistinctBy(r'txType');
});
}
QueryBuilder<Transaction, Transaction, QDistinct> distinctByTxid( QueryBuilder<Transaction, Transaction, QDistinct> distinctByTxid(
{bool caseSensitive = true}) { {bool caseSensitive = true}) {
return QueryBuilder.apply(this, (query) { return QueryBuilder.apply(this, (query) {
return query.addDistinctBy(r'txid', caseSensitive: caseSensitive); return query.addDistinctBy(r'txid', caseSensitive: caseSensitive);
}); });
} }
QueryBuilder<Transaction, Transaction, QDistinct> distinctByType() {
return QueryBuilder.apply(this, (query) {
return query.addDistinctBy(r'type');
});
}
} }
extension TransactionQueryProperty extension TransactionQueryProperty
@ -1850,16 +1851,15 @@ extension TransactionQueryProperty
}); });
} }
QueryBuilder<Transaction, TransactionType, QQueryOperations>
txTypeProperty() {
return QueryBuilder.apply(this, (query) {
return query.addPropertyName(r'txType');
});
}
QueryBuilder<Transaction, String, QQueryOperations> txidProperty() { QueryBuilder<Transaction, String, QQueryOperations> txidProperty() {
return QueryBuilder.apply(this, (query) { return QueryBuilder.apply(this, (query) {
return query.addPropertyName(r'txid'); return query.addPropertyName(r'txid');
}); });
} }
QueryBuilder<Transaction, TransactionType, QQueryOperations> typeProperty() {
return QueryBuilder.apply(this, (query) {
return query.addPropertyName(r'type');
});
}
} }

View file

@ -13,7 +13,6 @@ class Log {
@Index() @Index()
late int timestampInMillisUTC; late int timestampInMillisUTC;
// ignore: undefined_name
@Enumerated(EnumType.name) @Enumerated(EnumType.name)
late LogLevel logLevel; late LogLevel logLevel;