File tree 2 files changed +17
-25
lines changed
packages/restate-e2e-services 2 files changed +17
-25
lines changed Original file line number Diff line number Diff line change 1
- FROM node:20 AS build
1
+ FROM node:20
2
2
3
3
WORKDIR /usr/src/app
4
4
@@ -9,18 +9,9 @@ RUN npm install
9
9
RUN npm run proto
10
10
RUN npm run build
11
11
12
- FROM node:20 as prod
13
- WORKDIR /usr/src/app
14
-
15
- # Install app dependencies
16
- COPY ./packages/restate-e2e-services/package*.json ./
17
- RUN npm install --production
18
-
19
- COPY --from=build /usr/src/app/packages/restate-e2e-services/dist /usr/src/app/dist
20
-
21
12
# Install Tini
22
13
RUN apt-get update && apt-get -y install tini
23
14
24
15
EXPOSE 8080
25
16
ENTRYPOINT ["tini" , "--" ]
26
- CMD ["node" , "/usr/src/app/dist/src/app.js" ]
17
+ CMD ["node" , "/usr/src/app/packages/restate-e2e-services/ dist/src/app.js" ]
Original file line number Diff line number Diff line change @@ -33,12 +33,14 @@ async function rawCall(
33
33
key ?: string
34
34
) {
35
35
const input = new Uint8Array ( message ) ;
36
- const response : Uint8Array = await ( ctx as any ) . invoke (
37
- serviceName ,
38
- handlerName ,
39
- input ,
40
- key
41
- ) ;
36
+ const response : Uint8Array = await ctx . genericCall ( {
37
+ service : serviceName ,
38
+ method : handlerName ,
39
+ key : key ,
40
+ inputSerde : restate . serde . binary ,
41
+ outputSerde : restate . serde . binary ,
42
+ parameter : input ,
43
+ } ) ;
42
44
43
45
return Array . from ( response ) ;
44
46
}
@@ -51,14 +53,13 @@ async function rawSend(
51
53
key ?: string
52
54
) {
53
55
const input = new Uint8Array ( message ) ;
54
- await ( ctx as any ) . invokeOneWay (
55
- serviceName ,
56
- handlerName ,
57
- input ,
58
- undefined ,
59
- undefined ,
60
- key
61
- ) ;
56
+ ctx . genericSend ( {
57
+ service : serviceName ,
58
+ method : handlerName ,
59
+ key : key ,
60
+ inputSerde : restate . serde . binary ,
61
+ parameter : input ,
62
+ } ) ;
62
63
}
63
64
64
65
const o = restate . service ( {
You can’t perform that action at this time.
0 commit comments