Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Objectbox in Isolate #18

Open
wants to merge 14 commits into
base: main
Choose a base branch
from
+1,427 −688
Open

Objectbox in Isolate #18

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
14 commits
Select commit Hold shift + click to select a range
fa881cf
for Flutter 3.24.3
iebb Sep 26, 2024
f580a57
change to vertical
iebb Sep 26, 2024
ede757e
debug ver.
iebb Oct 4, 2024
55067a0
isolated
iebb Oct 4, 2024
0a4f35d
adapter done
iebb Oct 4, 2024
5003633
demo replication works
iebb Oct 4, 2024
80e3b8f
remove debugging codes
iebb Oct 7, 2024
839cf07
fvm version
iebb Oct 7, 2024
395bb3b
fix multiple openings
iebb Oct 7, 2024
d3171fe
couchdb
iebb Oct 7, 2024
0092b12
fix tests
iebb Oct 7, 2024
2ccbb69
flutter 3.22.3
iebb Oct 15, 2024
1ab9bf0
fix: use fromReference instead of attach, to make it close properly
iebb Oct 17, 2024
65682c9
fix: use number as commands to make it faster
iebb Oct 17, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 3 additions & 0 deletions foodb/lib/foodb.dart
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,8 @@ library foodb;

import 'dart:async';
import 'dart:convert';
import 'dart:io';
import 'dart:isolate';
import 'package:crypto/crypto.dart' as crypto;
import 'package:foodb/src/common.dart';
import 'package:foodb/src/methods/purge.dart';
Expand All @@ -28,6 +30,7 @@ import 'package:synchronized/synchronized.dart';
import 'package:uuid/uuid.dart';

export 'package:foodb/src/replicate.dart';
export 'package:foodb/src/replication_utils.dart';
export 'package:foodb/src/selector.dart';
export 'package:foodb/src/common.dart';
export 'package:foodb/src/design_doc.dart';
Expand Down
12 changes: 6 additions & 6 deletions foodb/lib/src/key_value/collate.dart
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -203,11 +203,11 @@ _Encoder _getEncoderByCollationType(String key) {

String encodeToIndex(dynamic key) {
final encoder = _getEncoderByRuntimeType(key);
return encoder.COLLATION_TYPE_STR + encoder.encode(key) + RESERVED_DELIMITER;
return '${encoder.COLLATION_TYPE_STR}${encoder.encode(key)}$RESERVED_DELIMITER';
}

dynamic decodeFromIndex(String str) {
String strToParse = "";
StringBuffer buffer = StringBuffer();
_Encoder? encoder;
Queue<List<dynamic>> valueStack = Queue();
Queue<_Encoder> collectionStack = Queue();
Expand Down Expand Up @@ -235,15 +235,15 @@ dynamic decodeFromIndex(String str) {
if (encoder is _ArrEncoder || encoder is _ObjEncoder) {
valueStack.add([]);
collectionStack.addLast(encoder);
strToParse = '';
buffer = StringBuffer();
encoder = null;
}
continue;
}

// reached the end of string, time to run encoder
if (c == RESERVED_DELIMITER) {
final value = encoder.decode(strToParse);
final value = encoder.decode(buffer.toString());

// if the value is for the collection, add to stack
// else return
Expand All @@ -252,10 +252,10 @@ dynamic decodeFromIndex(String str) {
} else {
return value;
}
strToParse = '';
buffer = StringBuffer();
encoder = null;
continue;
}
strToParse += c;
buffer.write(c);
}
}
Loading