Compare commits
4 Commits
Author | SHA1 | Date | |
---|---|---|---|
7ba188eb6c | |||
188619478e | |||
27f21a23fe | |||
d78db03d5d |
@@ -2,7 +2,6 @@ import 'dart:async';
|
||||
import 'dart:io';
|
||||
import 'package:flutter/material.dart';
|
||||
import 'package:flutter/services.dart';
|
||||
import 'package:journaler/db.dart';
|
||||
import 'package:journaler/notes.dart';
|
||||
import 'package:journaler/utils.dart';
|
||||
import 'package:system_tray/system_tray.dart';
|
||||
@@ -309,11 +308,13 @@ class MainPageState extends State<MainPage> with WindowListener {
|
||||
final TextEditingController _intervalController = TextEditingController();
|
||||
final TextEditingController _soundController = TextEditingController();
|
||||
final TextEditingController _searchController = TextEditingController();
|
||||
final FocusNode _keyboardListenerFocusNode = FocusNode(); // Add persistent focus node
|
||||
|
||||
Note? previousNote;
|
||||
Note? _currentlyDisplayedNote;
|
||||
Duration _currentPopupInterval = _defaultPopupInterval;
|
||||
String _currentNotificationSound = _defaultNotificationSound;
|
||||
String? _originalScratchContent; // Track original scratch content
|
||||
|
||||
bool _canGoPrevious = false;
|
||||
bool _canGoNext = false;
|
||||
@@ -359,6 +360,7 @@ class MainPageState extends State<MainPage> with WindowListener {
|
||||
_previousEntryController.dispose();
|
||||
_currentEntryController.dispose();
|
||||
_currentEntryFocusNode.dispose();
|
||||
_keyboardListenerFocusNode.dispose(); // Dispose the keyboard listener focus node
|
||||
_scratchController.dispose();
|
||||
_intervalController.dispose();
|
||||
_soundController.dispose();
|
||||
@@ -424,13 +426,16 @@ class MainPageState extends State<MainPage> with WindowListener {
|
||||
await windowManager.setSize(const Size(1600, 900));
|
||||
await windowManager.center();
|
||||
|
||||
// Now show and focus
|
||||
// Show and focus immediately
|
||||
await windowManager.show();
|
||||
await Future.delayed(const Duration(milliseconds: 100)); // Short delay
|
||||
await windowManager.focus();
|
||||
|
||||
// Set input focus
|
||||
_currentEntryFocusNode.requestFocus();
|
||||
// Set input focus with a post-frame callback to ensure it sticks
|
||||
WidgetsBinding.instance.addPostFrameCallback((_) {
|
||||
if (mounted) {
|
||||
_currentEntryFocusNode.requestFocus();
|
||||
}
|
||||
});
|
||||
|
||||
// Play notification sound
|
||||
await _playSound();
|
||||
@@ -439,7 +444,11 @@ class MainPageState extends State<MainPage> with WindowListener {
|
||||
} else {
|
||||
// Already visible, just focus
|
||||
await windowManager.focus();
|
||||
_currentEntryFocusNode.requestFocus();
|
||||
WidgetsBinding.instance.addPostFrameCallback((_) {
|
||||
if (mounted) {
|
||||
_currentEntryFocusNode.requestFocus();
|
||||
}
|
||||
});
|
||||
debugPrint("Window already visible, just focused");
|
||||
}
|
||||
|
||||
@@ -563,6 +572,7 @@ class MainPageState extends State<MainPage> with WindowListener {
|
||||
|
||||
final scratch = await getLatestScratch();
|
||||
_scratchController.text = scratch?.content ?? "";
|
||||
_originalScratchContent = scratch?.content; // Store original content
|
||||
|
||||
await _checkNavigation();
|
||||
|
||||
@@ -597,9 +607,10 @@ class MainPageState extends State<MainPage> with WindowListener {
|
||||
_currentEntryController.clear(); // Clear the input field after saving
|
||||
}
|
||||
|
||||
if (scratchContent != _scratchController.text) {
|
||||
// Was modified
|
||||
// Only create new scratch if content has changed
|
||||
if (scratchContent != _originalScratchContent) {
|
||||
await createScratch(scratchContent);
|
||||
_originalScratchContent = scratchContent; // Update original content
|
||||
}
|
||||
|
||||
// Handle previous/currently displayed note
|
||||
@@ -1227,9 +1238,7 @@ class MainPageState extends State<MainPage> with WindowListener {
|
||||
Widget build(BuildContext context) {
|
||||
// Wrap Scaffold with RawKeyboardListener as workaround for Escape key
|
||||
return RawKeyboardListener(
|
||||
focusNode:
|
||||
FocusNode()
|
||||
..requestFocus(), // Request focus to ensure keyboard events are captured
|
||||
focusNode: _keyboardListenerFocusNode, // Use persistent focus node
|
||||
onKey: (RawKeyEvent event) {
|
||||
if (event is RawKeyDownEvent) {
|
||||
// Handle Escape to close window
|
||||
@@ -1238,8 +1247,7 @@ class MainPageState extends State<MainPage> with WindowListener {
|
||||
"Escape pressed inside MainPage (RawKeyboardListener - Workaround)",
|
||||
);
|
||||
// Call method directly since we are in the state
|
||||
FocusManager.instance.primaryFocus
|
||||
?.unfocus(); // Keep unfocus attempt
|
||||
FocusManager.instance.primaryFocus?.unfocus(); // Keep unfocus attempt
|
||||
onWindowClose();
|
||||
}
|
||||
// Handle Ctrl+F to open search
|
||||
|
220
lib/meilifix.dart
Normal file
220
lib/meilifix.dart
Normal file
@@ -0,0 +1,220 @@
|
||||
import 'dart:convert';
|
||||
import 'dart:core';
|
||||
import 'package:http/http.dart' as http;
|
||||
import 'package:journaler/meilisearch_config.dart';
|
||||
|
||||
const noteIndex = 'notes';
|
||||
const scratchIndex = 'scratch';
|
||||
final alphanum = RegExp(r'[a-zA-Z0-9]', caseSensitive: false);
|
||||
|
||||
class MeilisearchQuery {
|
||||
String q;
|
||||
String? filter;
|
||||
int? limit;
|
||||
int? offset;
|
||||
bool? showRankingScore;
|
||||
double? rankingScoreThreshold;
|
||||
String? highlightPreTag;
|
||||
String? highlightPostTag;
|
||||
List<String>? attributesToHighlight;
|
||||
List<String>? sort;
|
||||
|
||||
MeilisearchQuery({
|
||||
required this.q,
|
||||
this.filter,
|
||||
this.sort,
|
||||
this.limit,
|
||||
this.offset,
|
||||
this.showRankingScore,
|
||||
this.rankingScoreThreshold,
|
||||
this.highlightPreTag,
|
||||
this.highlightPostTag,
|
||||
this.attributesToHighlight,
|
||||
});
|
||||
|
||||
Map<String, dynamic> toJson() {
|
||||
final Map<String, dynamic> json = {'q': q};
|
||||
if (filter != null) json['filter'] = filter;
|
||||
if (sort != null) json['sort'] = sort;
|
||||
if (limit != null) json['limit'] = limit;
|
||||
if (offset != null) json['offset'] = offset;
|
||||
if (showRankingScore != null) json['showRankingScore'] = showRankingScore;
|
||||
if (rankingScoreThreshold != null) {
|
||||
json['rankingScoreThreshold'] = rankingScoreThreshold;
|
||||
}
|
||||
if (highlightPreTag != null) json['highlightPreTag'] = highlightPreTag;
|
||||
if (highlightPostTag != null) json['highlightPostTag'] = highlightPostTag;
|
||||
if (attributesToHighlight != null) {
|
||||
json['attributesToHighlight'] = attributesToHighlight;
|
||||
}
|
||||
return json;
|
||||
}
|
||||
}
|
||||
|
||||
class MeilisearchResponse {
|
||||
final List<dynamic> hits;
|
||||
final String query;
|
||||
final int processingTimeMs;
|
||||
final int limit;
|
||||
final int offset;
|
||||
final int estimatedTotalHits;
|
||||
|
||||
MeilisearchResponse({
|
||||
required this.hits,
|
||||
required this.query,
|
||||
required this.processingTimeMs,
|
||||
required this.limit,
|
||||
required this.offset,
|
||||
required this.estimatedTotalHits,
|
||||
});
|
||||
|
||||
static MeilisearchResponse fromJson(Map<String, dynamic> json) {
|
||||
return MeilisearchResponse(
|
||||
hits: json['hits'],
|
||||
query: json['query'],
|
||||
processingTimeMs: json['processingTimeMs'],
|
||||
limit: json['limit'],
|
||||
offset: json['offset'],
|
||||
estimatedTotalHits: json['estimatedTotalHits'],
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
Future<Map<String, String>> _getHeaders() async {
|
||||
final apiKey = await getMeilisearchApiKey();
|
||||
return {
|
||||
'Authorization': 'Bearer $apiKey',
|
||||
'Content-Type': 'application/json',
|
||||
};
|
||||
}
|
||||
|
||||
Future<String> _getEndpoint() async {
|
||||
return await getMeilisearchEndpoint();
|
||||
}
|
||||
|
||||
Future<List<Map<String, dynamic>>> getAllDocuments(String index) async {
|
||||
final endpoint = await _getEndpoint();
|
||||
final headers = await _getHeaders();
|
||||
final allDocuments = <Map<String, dynamic>>[];
|
||||
var offset = 0;
|
||||
const limit = 100;
|
||||
|
||||
while (true) {
|
||||
final response = await http.get(
|
||||
Uri.parse('$endpoint/indexes/$index/documents?limit=$limit&offset=$offset'),
|
||||
headers: headers,
|
||||
);
|
||||
if (response.statusCode != 200) {
|
||||
throw Exception('Failed to get documents: ${response.statusCode}');
|
||||
}
|
||||
final responseJson = jsonDecode(response.body);
|
||||
final documents = List<Map<String, dynamic>>.from(responseJson['results']);
|
||||
|
||||
if (documents.isEmpty) {
|
||||
break;
|
||||
}
|
||||
|
||||
allDocuments.addAll(documents);
|
||||
print('Found ${allDocuments.length} documents so far in $index');
|
||||
|
||||
if (documents.length < limit) {
|
||||
break;
|
||||
}
|
||||
|
||||
offset += limit;
|
||||
}
|
||||
|
||||
print('Total documents found in $index: ${allDocuments.length}');
|
||||
return allDocuments;
|
||||
}
|
||||
|
||||
Map<String, dynamic> fixDocument(Map<String, dynamic> doc) {
|
||||
final content = doc['content'] as String;
|
||||
final date = doc['date'] as int;
|
||||
|
||||
// Calculate letter frequency
|
||||
final letterFrequency = <String, int>{};
|
||||
for (final char in content.split('')) {
|
||||
if (alphanum.hasMatch(char)) {
|
||||
letterFrequency[char] = (letterFrequency[char] ?? 0) + 1;
|
||||
}
|
||||
}
|
||||
|
||||
final mostFrequentLetter =
|
||||
letterFrequency.entries.isEmpty
|
||||
? 'a'
|
||||
: letterFrequency.entries
|
||||
.reduce((a, b) => a.value > b.value ? a : b)
|
||||
.key;
|
||||
|
||||
final mostFrequentLetterCount =
|
||||
letterFrequency.isEmpty
|
||||
? 0.0
|
||||
: letterFrequency[mostFrequentLetter]! / content.length;
|
||||
|
||||
return {
|
||||
...doc,
|
||||
'dateISO':
|
||||
DateTime.fromMillisecondsSinceEpoch(date).toUtc().toIso8601String(),
|
||||
'topLetter': mostFrequentLetter,
|
||||
'topLetterFrequency': mostFrequentLetterCount,
|
||||
};
|
||||
}
|
||||
|
||||
Future<void> updateDocument(String index, Map<String, dynamic> doc) async {
|
||||
final endpoint = await _getEndpoint();
|
||||
final headers = await _getHeaders();
|
||||
final response = await http.post(
|
||||
Uri.parse('$endpoint/indexes/$index/documents'),
|
||||
headers: headers,
|
||||
body: jsonEncode(doc),
|
||||
);
|
||||
if (response.statusCode != 202) {
|
||||
throw Exception('Failed to update document: ${response.statusCode}');
|
||||
}
|
||||
}
|
||||
|
||||
Future<void> fixAllDocuments() async {
|
||||
print('Fixing notes...');
|
||||
final notes = await getAllDocuments(noteIndex);
|
||||
final noteBatches = <List<Map<String, dynamic>>>[];
|
||||
for (var i = 0; i < notes.length; i += 10) {
|
||||
noteBatches.add(notes.skip(i).take(10).toList());
|
||||
}
|
||||
|
||||
for (final batch in noteBatches) {
|
||||
await Future.wait(
|
||||
batch.map((note) async {
|
||||
final fixed = fixDocument(note);
|
||||
await updateDocument(noteIndex, fixed);
|
||||
print('Fixed note: ${note['id']}');
|
||||
}),
|
||||
);
|
||||
}
|
||||
|
||||
print('Fixing scratches...');
|
||||
final scratches = await getAllDocuments(scratchIndex);
|
||||
final scratchBatches = <List<Map<String, dynamic>>>[];
|
||||
for (var i = 0; i < scratches.length; i += 10) {
|
||||
scratchBatches.add(scratches.skip(i).take(10).toList());
|
||||
}
|
||||
|
||||
for (final batch in scratchBatches) {
|
||||
await Future.wait(
|
||||
batch.map((scratch) async {
|
||||
final fixed = fixDocument(scratch);
|
||||
await updateDocument(scratchIndex, fixed);
|
||||
print('Fixed scratch: ${scratch['id']}');
|
||||
}),
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
void main() async {
|
||||
try {
|
||||
await fixAllDocuments();
|
||||
print('All documents fixed successfully!');
|
||||
} catch (e) {
|
||||
print('Error fixing documents: $e');
|
||||
}
|
||||
}
|
@@ -142,6 +142,11 @@ Future<void> init() async {
|
||||
body: jsonEncode({'uid': settingsIndex, 'primaryKey': 'key'}),
|
||||
);
|
||||
}
|
||||
await http.put(
|
||||
Uri.parse('$endpoint/indexes/$settingsIndex/settings/filterable-attributes'),
|
||||
headers: headers,
|
||||
body: jsonEncode(['key', 'value']),
|
||||
);
|
||||
}
|
||||
|
||||
Future<bool> indexExists(String index) async {
|
||||
|
Reference in New Issue
Block a user