Skip to content

Commit bdeb57b

Browse files
authored
chore(celest): Use context HTTP client for DB connections (#398)
To ensure that HTTP timeouts and retry behavior are centralized and overridable, use the context's HTTP client for Hrana connections.
1 parent a990ac9 commit bdeb57b

File tree

2 files changed

+5
-2
lines changed

2 files changed

+5
-2
lines changed

packages/celest/lib/src/runtime/data/celest_database.dart

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -90,6 +90,7 @@ sealed class CelestDatabase<Database extends GeneratedDatabase> {
9090
},
9191
),
9292
jwtToken: token,
93+
httpClient: context.httpClient,
9394
);
9495
return LibsqlDatabase(
9596
uri: uri,

services/celest_cloud_hub/bin/cloud_hub.dart

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ import 'dart:io';
44
import 'package:async/async.dart';
55
import 'package:cedar/cedar.dart';
66
import 'package:celest/celest.dart';
7-
import 'package:celest/src/runtime/data/connect.dart';
7+
import 'package:celest/src/runtime/data/celest_database.dart';
88
import 'package:celest_cloud_auth/celest_cloud_auth.dart';
99
import 'package:celest_cloud_auth/src/authorization/authorizer.dart';
1010
import 'package:celest_cloud_auth/src/authorization/corks_repository.dart';
@@ -100,12 +100,14 @@ Future<void> main() async {
100100

101101
Future<void> _run() async {
102102
context.logger.config('Configuring Cloud Hub database');
103-
final db = await connect(
103+
final celestDb = await CelestDatabase.create(
104104
Context.current,
105105
name: 'CloudHubDatabase',
106106
factory: CloudHubDatabase.new,
107107
hostnameVariable: const env('CLOUD_HUB_DATABASE_HOST'),
108108
tokenSecret: const secret('CLOUD_HUB_DATABASE_TOKEN'),
109+
);
110+
final db = await celestDb.connect(
109111
setup: (db) => db.addHelperFunctions(),
110112
logStatements: context.logger.level <= Level.FINEST,
111113
);

0 commit comments

Comments
 (0)