@@ -5,66 +5,54 @@ import { KvNamespaces } from './models/kv-namespaces.enum';
5
5
6
6
@Injectable ( )
7
7
export class CloudflareKvService implements OnModuleInit {
8
- private edgeKvUrl : string ;
9
- private authorizationToken : string ;
8
+ private edgeKvUrl : string ;
9
+ private authorizationToken : string ;
10
10
11
- constructor (
12
- private readonly configService : ConfigService ,
13
- private readonly logService : LogService ,
14
- ) { }
11
+ constructor (
12
+ private readonly configService : ConfigService ,
13
+ private readonly logService : LogService
14
+ ) { }
15
15
16
- onModuleInit ( ) {
17
- this . edgeKvUrl = this . configService . get ( 'EDGE_KV_URL' ) ;
18
- this . authorizationToken = this . configService . get (
19
- 'EDGE_KV_AUTHORIZATION_TOKEN' ,
20
- ) ;
21
- }
22
-
23
- async createKeyValueForNamespace (
24
- namespace : KvNamespaces ,
25
- key : string ,
26
- value ?: string | object ,
27
- ) {
28
- try {
29
- const requestOptions = {
30
- method : 'POST' ,
31
- headers : {
32
- authorizationToken : this . authorizationToken ,
33
- } ,
34
- } ;
35
-
36
- const response = await fetch (
37
- `${ this . edgeKvUrl } /${ namespace } /${ key } ` ,
38
- requestOptions ,
39
- ) ;
40
-
41
- return response ;
42
- } catch ( e ) {
43
- this . logService . error ( 'Failed to update workers KV' , {
44
- errorMessage : e . message ,
45
- } ) ;
16
+ onModuleInit ( ) {
17
+ this . edgeKvUrl = this . configService . get ( 'EDGE_KV_URL' ) ;
18
+ this . authorizationToken = this . configService . get ( 'EDGE_KV_AUTHORIZATION_TOKEN' ) ;
46
19
}
47
- }
48
20
49
- async deleteKeyForNamespace ( namespace : KvNamespaces , key : string ) {
50
- try {
51
- const requestOptions = {
52
- method : 'DELETE' ,
53
- headers : {
54
- authorizationToken : this . authorizationToken ,
55
- } ,
56
- } ;
57
-
58
- const response = await fetch (
59
- `${ this . edgeKvUrl } /${ namespace } /${ key } ` ,
60
- requestOptions ,
61
- ) ;
21
+ async createKeyValueForNamespace ( namespace : KvNamespaces , key : string , value ?: string | object ) {
22
+ try {
23
+ const requestOptions = {
24
+ method : 'POST' ,
25
+ headers : {
26
+ authorizationToken : this . authorizationToken ,
27
+ } ,
28
+ } ;
29
+
30
+ const response = await fetch ( `${ this . edgeKvUrl } /${ namespace } /${ key } ` , requestOptions ) ;
31
+
32
+ return response ;
33
+ } catch ( e ) {
34
+ this . logService . error ( 'Failed to update workers KV' , {
35
+ errorMessage : e . message ,
36
+ } ) ;
37
+ }
38
+ }
62
39
63
- return response . json ( ) ;
64
- } catch ( e ) {
65
- this . logService . error ( 'Failed to update workers KV' , {
66
- errorMessage : e . message ,
67
- } ) ;
40
+ async deleteKeyForNamespace ( namespace : KvNamespaces , key : string ) {
41
+ try {
42
+ const requestOptions = {
43
+ method : 'DELETE' ,
44
+ headers : {
45
+ authorizationToken : this . authorizationToken ,
46
+ } ,
47
+ } ;
48
+
49
+ const response = await fetch ( `${ this . edgeKvUrl } /${ namespace } /${ key } ` , requestOptions ) ;
50
+
51
+ return response . json ( ) ;
52
+ } catch ( e ) {
53
+ this . logService . error ( 'Failed to update workers KV' , {
54
+ errorMessage : e . message ,
55
+ } ) ;
56
+ }
68
57
}
69
- }
70
58
}
0 commit comments