Skip to content

Commit 17b657c

Browse files
eliasdarrudaeliasdarruda
committed
release 1.0.0
1 parent 19819c1 commit 17b657c

File tree

3 files changed

+80
-81
lines changed

3 files changed

+80
-81
lines changed

‎README.md

+1-2
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,6 @@ services:
4545
4646
> **NOTE:** `Windows w/ WSL2` - If you want to use docker for spawn-proxy and local host for your NodeJS check this article https://www.beyondjava.net/docker-wsl-network
4747

48-
4948
Set the following ENV variables for your NodeJS runtime (following .env.example)
5049

5150
```bash
@@ -54,7 +53,7 @@ PROXY_HTTP_HOST=localhost
5453
USER_FUNCTION_PORT=8090
5554
```
5655

57-
Define a protobuf file (lets save this at `protos/examples/user_example.proto`)
56+
Define a protobuf file (lets save this at `protos/examples/user_example.proto`), if you want to skip this part, you can use 'json' type actors.
5857

5958
```proto
6059
syntax = "proto3";

‎package.json

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "@eigr/spawn-sdk",
3-
"version": "0.5.5",
3+
"version": "1.0.0",
44
"description": "Spawn Actor model framework implementation for NodeJS",
55
"main": "_build/index.js",
66
"types": "_build/index.d.ts",

‎test/protos/user_test.ts

+78-78
Original file line numberDiff line numberDiff line change
@@ -1,28 +1,28 @@
11
// @generated by protobuf-ts 2.7.0
22
// @generated from protobuf file "user_test.proto" (syntax proto3)
33
// tslint:disable
4-
import type { BinaryWriteOptions } from '@protobuf-ts/runtime';
5-
import type { IBinaryWriter } from '@protobuf-ts/runtime';
6-
import { WireType } from '@protobuf-ts/runtime';
7-
import type { BinaryReadOptions } from '@protobuf-ts/runtime';
8-
import type { IBinaryReader } from '@protobuf-ts/runtime';
9-
import { UnknownFieldHandler } from '@protobuf-ts/runtime';
10-
import type { PartialMessage } from '@protobuf-ts/runtime';
11-
import { reflectionMergePartial } from '@protobuf-ts/runtime';
12-
import { MESSAGE_TYPE } from '@protobuf-ts/runtime';
13-
import { MessageType } from '@protobuf-ts/runtime';
4+
import type { BinaryWriteOptions } from '@protobuf-ts/runtime'
5+
import type { IBinaryWriter } from '@protobuf-ts/runtime'
6+
import { WireType } from '@protobuf-ts/runtime'
7+
import type { BinaryReadOptions } from '@protobuf-ts/runtime'
8+
import type { IBinaryReader } from '@protobuf-ts/runtime'
9+
import { UnknownFieldHandler } from '@protobuf-ts/runtime'
10+
import type { PartialMessage } from '@protobuf-ts/runtime'
11+
import { reflectionMergePartial } from '@protobuf-ts/runtime'
12+
import { MESSAGE_TYPE } from '@protobuf-ts/runtime'
13+
import { MessageType } from '@protobuf-ts/runtime'
1414
/**
1515
* @generated from protobuf message UserState
1616
*/
1717
export interface UserState {
1818
/**
1919
* @generated from protobuf field: string name = 1;
2020
*/
21-
name: string;
21+
name: string
2222
/**
2323
* @generated from protobuf field: optional string nickname = 2;
2424
*/
25-
nickname?: string;
25+
nickname?: string
2626
}
2727
/**
2828
* @generated from protobuf message ChangeUserName
@@ -31,7 +31,7 @@ export interface ChangeUserName {
3131
/**
3232
* @generated from protobuf field: string new_name = 1;
3333
*/
34-
newName: string;
34+
newName: string
3535
}
3636
/**
3737
* @generated from protobuf message ChangeUserNameResponse
@@ -40,11 +40,11 @@ export interface ChangeUserNameResponse {
4040
/**
4141
* @generated from protobuf field: ChangeUserNameStatus status = 1;
4242
*/
43-
status: ChangeUserNameStatus;
43+
status: ChangeUserNameStatus
4444
/**
4545
* @generated from protobuf field: string new_name = 2;
4646
*/
47-
newName: string;
47+
newName: string
4848
}
4949
/**
5050
* @generated from protobuf enum ChangeUserNameStatus
@@ -65,13 +65,13 @@ class UserState$Type extends MessageType<UserState> {
6565
super('UserState', [
6666
{ no: 1, name: 'name', kind: 'scalar', T: 9 /*ScalarType.STRING*/ },
6767
{ no: 2, name: 'nickname', kind: 'scalar', opt: true, T: 9 /*ScalarType.STRING*/ }
68-
]);
68+
])
6969
}
7070
create(value?: PartialMessage<UserState>): UserState {
71-
const message = { name: '' };
72-
globalThis.Object.defineProperty(message, MESSAGE_TYPE, { enumerable: false, value: this });
73-
if (value !== undefined) reflectionMergePartial<UserState>(this, message, value);
74-
return message;
71+
const message = { name: '' }
72+
globalThis.Object.defineProperty(message, MESSAGE_TYPE, { enumerable: false, value: this })
73+
if (value !== undefined) reflectionMergePartial<UserState>(this, message, value)
74+
return message
7575
}
7676
internalBinaryRead(
7777
reader: IBinaryReader,
@@ -80,66 +80,66 @@ class UserState$Type extends MessageType<UserState> {
8080
target?: UserState
8181
): UserState {
8282
let message = target ?? this.create(),
83-
end = reader.pos + length;
83+
end = reader.pos + length
8484
while (reader.pos < end) {
85-
let [fieldNo, wireType] = reader.tag();
85+
let [fieldNo, wireType] = reader.tag()
8686
switch (fieldNo) {
8787
case /* string name */ 1:
88-
message.name = reader.string();
89-
break;
88+
message.name = reader.string()
89+
break
9090
case /* optional string nickname */ 2:
91-
message.nickname = reader.string();
92-
break;
91+
message.nickname = reader.string()
92+
break
9393
default:
94-
let u = options.readUnknownField;
94+
let u = options.readUnknownField
9595
if (u === 'throw')
9696
throw new globalThis.Error(
9797
`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`
98-
);
99-
let d = reader.skip(wireType);
98+
)
99+
let d = reader.skip(wireType)
100100
if (u !== false)
101101
(u === true ? UnknownFieldHandler.onRead : u)(
102102
this.typeName,
103103
message,
104104
fieldNo,
105105
wireType,
106106
d
107-
);
107+
)
108108
}
109109
}
110-
return message;
110+
return message
111111
}
112112
internalBinaryWrite(
113113
message: UserState,
114114
writer: IBinaryWriter,
115115
options: BinaryWriteOptions
116116
): IBinaryWriter {
117117
/* string name = 1; */
118-
if (message.name !== '') writer.tag(1, WireType.LengthDelimited).string(message.name);
118+
if (message.name !== '') writer.tag(1, WireType.LengthDelimited).string(message.name)
119119
/* optional string nickname = 2; */
120120
if (message.nickname !== undefined)
121-
writer.tag(2, WireType.LengthDelimited).string(message.nickname);
122-
let u = options.writeUnknownFields;
123-
if (u !== false) (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
124-
return writer;
121+
writer.tag(2, WireType.LengthDelimited).string(message.nickname)
122+
let u = options.writeUnknownFields
123+
if (u !== false) (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer)
124+
return writer
125125
}
126126
}
127127
/**
128128
* @generated MessageType for protobuf message UserState
129129
*/
130-
export const UserState = new UserState$Type();
130+
export const UserState = new UserState$Type()
131131
// @generated message type with reflection information, may provide speed optimized methods
132132
class ChangeUserName$Type extends MessageType<ChangeUserName> {
133133
constructor() {
134134
super('ChangeUserName', [
135135
{ no: 1, name: 'new_name', kind: 'scalar', T: 9 /*ScalarType.STRING*/ }
136-
]);
136+
])
137137
}
138138
create(value?: PartialMessage<ChangeUserName>): ChangeUserName {
139-
const message = { newName: '' };
140-
globalThis.Object.defineProperty(message, MESSAGE_TYPE, { enumerable: false, value: this });
141-
if (value !== undefined) reflectionMergePartial<ChangeUserName>(this, message, value);
142-
return message;
139+
const message = { newName: '' }
140+
globalThis.Object.defineProperty(message, MESSAGE_TYPE, { enumerable: false, value: this })
141+
if (value !== undefined) reflectionMergePartial<ChangeUserName>(this, message, value)
142+
return message
143143
}
144144
internalBinaryRead(
145145
reader: IBinaryReader,
@@ -148,48 +148,48 @@ class ChangeUserName$Type extends MessageType<ChangeUserName> {
148148
target?: ChangeUserName
149149
): ChangeUserName {
150150
let message = target ?? this.create(),
151-
end = reader.pos + length;
151+
end = reader.pos + length
152152
while (reader.pos < end) {
153-
let [fieldNo, wireType] = reader.tag();
153+
let [fieldNo, wireType] = reader.tag()
154154
switch (fieldNo) {
155155
case /* string new_name */ 1:
156-
message.newName = reader.string();
157-
break;
156+
message.newName = reader.string()
157+
break
158158
default:
159-
let u = options.readUnknownField;
159+
let u = options.readUnknownField
160160
if (u === 'throw')
161161
throw new globalThis.Error(
162162
`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`
163-
);
164-
let d = reader.skip(wireType);
163+
)
164+
let d = reader.skip(wireType)
165165
if (u !== false)
166166
(u === true ? UnknownFieldHandler.onRead : u)(
167167
this.typeName,
168168
message,
169169
fieldNo,
170170
wireType,
171171
d
172-
);
172+
)
173173
}
174174
}
175-
return message;
175+
return message
176176
}
177177
internalBinaryWrite(
178178
message: ChangeUserName,
179179
writer: IBinaryWriter,
180180
options: BinaryWriteOptions
181181
): IBinaryWriter {
182182
/* string new_name = 1; */
183-
if (message.newName !== '') writer.tag(1, WireType.LengthDelimited).string(message.newName);
184-
let u = options.writeUnknownFields;
185-
if (u !== false) (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
186-
return writer;
183+
if (message.newName !== '') writer.tag(1, WireType.LengthDelimited).string(message.newName)
184+
let u = options.writeUnknownFields
185+
if (u !== false) (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer)
186+
return writer
187187
}
188188
}
189189
/**
190190
* @generated MessageType for protobuf message ChangeUserName
191191
*/
192-
export const ChangeUserName = new ChangeUserName$Type();
192+
export const ChangeUserName = new ChangeUserName$Type()
193193
// @generated message type with reflection information, may provide speed optimized methods
194194
class ChangeUserNameResponse$Type extends MessageType<ChangeUserNameResponse> {
195195
constructor() {
@@ -201,13 +201,13 @@ class ChangeUserNameResponse$Type extends MessageType<ChangeUserNameResponse> {
201201
T: () => ['ChangeUserNameStatus', ChangeUserNameStatus]
202202
},
203203
{ no: 2, name: 'new_name', kind: 'scalar', T: 9 /*ScalarType.STRING*/ }
204-
]);
204+
])
205205
}
206206
create(value?: PartialMessage<ChangeUserNameResponse>): ChangeUserNameResponse {
207-
const message = { status: 0, newName: '' };
208-
globalThis.Object.defineProperty(message, MESSAGE_TYPE, { enumerable: false, value: this });
209-
if (value !== undefined) reflectionMergePartial<ChangeUserNameResponse>(this, message, value);
210-
return message;
207+
const message = { status: 0, newName: '' }
208+
globalThis.Object.defineProperty(message, MESSAGE_TYPE, { enumerable: false, value: this })
209+
if (value !== undefined) reflectionMergePartial<ChangeUserNameResponse>(this, message, value)
210+
return message
211211
}
212212
internalBinaryRead(
213213
reader: IBinaryReader,
@@ -216,50 +216,50 @@ class ChangeUserNameResponse$Type extends MessageType<ChangeUserNameResponse> {
216216
target?: ChangeUserNameResponse
217217
): ChangeUserNameResponse {
218218
let message = target ?? this.create(),
219-
end = reader.pos + length;
219+
end = reader.pos + length
220220
while (reader.pos < end) {
221-
let [fieldNo, wireType] = reader.tag();
221+
let [fieldNo, wireType] = reader.tag()
222222
switch (fieldNo) {
223223
case /* ChangeUserNameStatus status */ 1:
224-
message.status = reader.int32();
225-
break;
224+
message.status = reader.int32()
225+
break
226226
case /* string new_name */ 2:
227-
message.newName = reader.string();
228-
break;
227+
message.newName = reader.string()
228+
break
229229
default:
230-
let u = options.readUnknownField;
230+
let u = options.readUnknownField
231231
if (u === 'throw')
232232
throw new globalThis.Error(
233233
`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`
234-
);
235-
let d = reader.skip(wireType);
234+
)
235+
let d = reader.skip(wireType)
236236
if (u !== false)
237237
(u === true ? UnknownFieldHandler.onRead : u)(
238238
this.typeName,
239239
message,
240240
fieldNo,
241241
wireType,
242242
d
243-
);
243+
)
244244
}
245245
}
246-
return message;
246+
return message
247247
}
248248
internalBinaryWrite(
249249
message: ChangeUserNameResponse,
250250
writer: IBinaryWriter,
251251
options: BinaryWriteOptions
252252
): IBinaryWriter {
253253
/* ChangeUserNameStatus status = 1; */
254-
if (message.status !== 0) writer.tag(1, WireType.Varint).int32(message.status);
254+
if (message.status !== 0) writer.tag(1, WireType.Varint).int32(message.status)
255255
/* string new_name = 2; */
256-
if (message.newName !== '') writer.tag(2, WireType.LengthDelimited).string(message.newName);
257-
let u = options.writeUnknownFields;
258-
if (u !== false) (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
259-
return writer;
256+
if (message.newName !== '') writer.tag(2, WireType.LengthDelimited).string(message.newName)
257+
let u = options.writeUnknownFields
258+
if (u !== false) (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer)
259+
return writer
260260
}
261261
}
262262
/**
263263
* @generated MessageType for protobuf message ChangeUserNameResponse
264264
*/
265-
export const ChangeUserNameResponse = new ChangeUserNameResponse$Type();
265+
export const ChangeUserNameResponse = new ChangeUserNameResponse$Type()

0 commit comments

Comments
 (0)