Skip to content

Commit

Permalink
chore: move gRPC client module root up
Browse files Browse the repository at this point in the history
  • Loading branch information
zepatrik committed Jun 15, 2021
1 parent e5b76b3 commit 05b2dbc
Show file tree
Hide file tree
Showing 19 changed files with 85 additions and 513 deletions.
Original file line number Diff line number Diff line change
@@ -1,18 +1,16 @@
import grpc from '@ory/keto-grpc-client/node_modules/@grpc/grpc-js/build/src/index.js'
import acl from '@ory/keto-grpc-client/acl_pb.js'
import writeService from '@ory/keto-grpc-client/write_service_grpc_pb.js'
import writeData from '@ory/keto-grpc-client/write_service_pb.js'
import { acl, write, writeService } from '@ory/keto-grpc-client'

const writeClient = new writeService.WriteServiceClient(
'127.0.0.1:4467',
grpc.credentials.createInsecure()
)

const writeRequest = new writeData.TransactRelationTuplesRequest()
const writeRequest = new write.TransactRelationTuplesRequest()

const insert = (tuple) => {
const tupleDelta = new writeData.RelationTupleDelta()
tupleDelta.setAction(writeData.RelationTupleDelta.Action.INSERT)
const tupleDelta = new write.RelationTupleDelta()
tupleDelta.setAction(write.RelationTupleDelta.Action.INSERT)
tupleDelta.setRelationTuple(tuple)

writeRequest.addRelationTupleDeltas(tupleDelta)
Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1,5 @@
import grpc from '@ory/keto-grpc-client/node_modules/@grpc/grpc-js/build/src/index.js'
import expandService from '@ory/keto-grpc-client/expand_service_grpc_pb.js'
import expandData from '@ory/keto-grpc-client/expand_service_pb.js'
import acl from '@ory/keto-grpc-client/acl_pb.js'
import { acl, expand, expandService } from '@ory/keto-grpc-client'

const expandClient = new expandService.ExpandServiceClient(
'127.0.0.1:4466',
Expand All @@ -16,7 +14,7 @@ subjectSet.setObject('/photos/beach.jpg')
const sub = new acl.Subject()
sub.setSet(subjectSet)

const expandRequest = new expandData.ExpandRequest()
const expandRequest = new expand.ExpandRequest()
expandRequest.setSubject(sub)
expandRequest.setMaxDepth(3)

Expand All @@ -37,9 +35,9 @@ const prettyTree = (tree) => {
tree.getChildrenList()
]
switch (nodeType) {
case expandData.NodeType.NODE_TYPE_LEAF:
case expand.NodeType.NODE_TYPE_LEAF:
return { type: 'leaf', subject }
case expandData.NodeType.NODE_TYPE_UNION:
case expand.NodeType.NODE_TYPE_UNION:
return { type: 'union', subject, children: children.map(prettyTree) }
}
}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,19 +1,16 @@
import grpc from '@ory/keto-grpc-client/node_modules/@grpc/grpc-js/build/src/index.js'
import writeService from '@ory/keto-grpc-client/write_service_grpc_pb.js'
import writeData from '@ory/keto-grpc-client/write_service_pb.js'
import readService from '@ory/keto-grpc-client/read_service_grpc_pb.js'
import readData from '@ory/keto-grpc-client/read_service_pb.js'
import { write, writeService, read, readService } from '@ory/keto-grpc-client'

const readClient = new readService.ReadServiceClient(
'127.0.0.1:4466',
grpc.credentials.createInsecure()
)

const purgeNamespace = (namespace) => {
const query = new readData.ListRelationTuplesRequest.Query()
const query = new read.ListRelationTuplesRequest.Query()
query.setNamespace(namespace)

const readRequest = new readData.ListRelationTuplesRequest()
const readRequest = new read.ListRelationTuplesRequest()
readRequest.setQuery(query)

readClient.listRelationTuples(readRequest, (err, resp) => {
Expand All @@ -22,11 +19,11 @@ const purgeNamespace = (namespace) => {
grpc.credentials.createInsecure()
)

const writeRequest = new writeData.TransactRelationTuplesRequest()
const writeRequest = new write.TransactRelationTuplesRequest()

resp.getRelationTuplesList().forEach((tuple) => {
const tupleDelta = new writeData.RelationTupleDelta()
tupleDelta.setAction(writeData.RelationTupleDelta.Action.DELETE)
const tupleDelta = new write.RelationTupleDelta()
tupleDelta.setAction(write.RelationTupleDelta.Action.DELETE)
tupleDelta.setRelationTuple(tuple)
writeRequest.addRelationTupleDeltas(tupleDelta)
})
Expand Down
Original file line number Diff line number Diff line change
@@ -1,14 +1,12 @@
import grpc from '@ory/keto-grpc-client/node_modules/@grpc/grpc-js/build/src/index.js'
import acl from '@ory/keto-grpc-client/acl_pb.js'
import writeService from '@ory/keto-grpc-client/write_service_grpc_pb.js'
import writeData from '@ory/keto-grpc-client/write_service_pb.js'
import { acl, write, writeService } from '@ory/keto-grpc-client'

const writeClient = new writeService.WriteServiceClient(
'127.0.0.1:4467',
grpc.credentials.createInsecure()
)

const writeRequest = new writeData.TransactRelationTuplesRequest()
const writeRequest = new write.TransactRelationTuplesRequest()

const addToChat = (chatName) => (user) => {
const relationTuple = new acl.RelationTuple()
Expand All @@ -20,8 +18,8 @@ const addToChat = (chatName) => (user) => {
sub.setId(user)
relationTuple.setSubject(sub)

const tupleDelta = new writeData.RelationTupleDelta()
tupleDelta.setAction(writeData.RelationTupleDelta.Action.INSERT)
const tupleDelta = new write.RelationTupleDelta()
tupleDelta.setAction(write.RelationTupleDelta.Action.INSERT)
tupleDelta.setRelationTuple(relationTuple)

writeRequest.addRelationTupleDeltas(tupleDelta)
Expand Down
Original file line number Diff line number Diff line change
@@ -1,15 +1,13 @@
import grpc from '@ory/keto-grpc-client/node_modules/@grpc/grpc-js/build/src/index.js'
import acl from '@ory/keto-grpc-client/acl_pb.js'
import readService from '@ory/keto-grpc-client/read_service_grpc_pb.js'
import readData from '@ory/keto-grpc-client/read_service_pb.js'
import { acl, read, readService } from '@ory/keto-grpc-client'

const readClient = new readService.ReadServiceClient(
'127.0.0.1:4466',
grpc.credentials.createInsecure()
)

const readRequest = new readData.ListRelationTuplesRequest()
const query = new readData.ListRelationTuplesRequest.Query()
const readRequest = new read.ListRelationTuplesRequest()
const query = new read.ListRelationTuplesRequest.Query()
query.setNamespace('chats')
query.setRelation('member')

Expand Down
Original file line number Diff line number Diff line change
@@ -1,15 +1,13 @@
import grpc from '@ory/keto-grpc-client/node_modules/@grpc/grpc-js/build/src/index.js'
import acl from '@ory/keto-grpc-client/acl_pb.js'
import readService from '@ory/keto-grpc-client/read_service_grpc_pb.js'
import readData from '@ory/keto-grpc-client/read_service_pb.js'
import { read, readService } from '@ory/keto-grpc-client'

const readClient = new readService.ReadServiceClient(
'127.0.0.1:4466',
grpc.credentials.createInsecure()
)

const readRequest = new readData.ListRelationTuplesRequest()
const query = new readData.ListRelationTuplesRequest.Query()
const readRequest = new read.ListRelationTuplesRequest()
const query = new read.ListRelationTuplesRequest.Query()
query.setNamespace('chats')
query.setObject('coffee-break')
query.setRelation('member')
Expand Down
Original file line number Diff line number Diff line change
@@ -1,18 +1,15 @@
import grpc from '@ory/keto-grpc-client/node_modules/@grpc/grpc-js/build/src/index.js'
import writeService from '@ory/keto-grpc-client/write_service_grpc_pb.js'
import writeData from '@ory/keto-grpc-client/write_service_pb.js'
import readService from '@ory/keto-grpc-client/read_service_grpc_pb.js'
import readData from '@ory/keto-grpc-client/read_service_pb.js'
import { write, writeService, read, readService } from '@ory/keto-grpc-client'

const readClient = new readService.ReadServiceClient(
'127.0.0.1:4466',
grpc.credentials.createInsecure()
)

const query = new readData.ListRelationTuplesRequest.Query()
const query = new read.ListRelationTuplesRequest.Query()
query.setNamespace('chats')

const readRequest = new readData.ListRelationTuplesRequest()
const readRequest = new read.ListRelationTuplesRequest()
readRequest.setQuery(query)

readClient.listRelationTuples(readRequest, (err, resp) => {
Expand All @@ -21,11 +18,11 @@ readClient.listRelationTuples(readRequest, (err, resp) => {
grpc.credentials.createInsecure()
)

const writeRequest = new writeData.TransactRelationTuplesRequest()
const writeRequest = new write.TransactRelationTuplesRequest()

resp.getRelationTuplesList().forEach((tuple) => {
const tupleDelta = new writeData.RelationTupleDelta()
tupleDelta.setAction(writeData.RelationTupleDelta.Action.DELETE)
const tupleDelta = new write.RelationTupleDelta()
tupleDelta.setAction(write.RelationTupleDelta.Action.DELETE)
tupleDelta.setRelationTuple(tuple)
writeRequest.addRelationTupleDeltas(tupleDelta)
})
Expand Down
Loading

0 comments on commit 05b2dbc

Please sign in to comment.