mitchell/selfpass
1
0
Fork 0
mirror of https://github.com/mitchell/selfpass.git synced 2025-12-14 21:27:22 +00:00
Code Issues Projects Releases Packages Wiki Activity

Modified client to use central selfpass protobuf package

Browse source
This commit is contained in:
mitchell 2019-07-11 23:15:30 -04:00
parent 4fc74b0994
commit fffdd53c18
12 changed files with 16 additions and 847 deletions
Download patch file Download diff file Expand all files Collapse all files

11
client/lib/repositories/grpc_credentials_client.dart
View file

@ -3,9 +3,8 @@ import 'dart:convert';
import 'dart:io';
import 'package:grpc/grpc.dart';
import '../protobuf/service.pbgrpc.dart' as grpc;
import '../protobuf/service.pb.dart' as protobuf;
import 'package:selfpass_protobuf/credentials.pbgrpc.dart' as grpc;
import 'package:selfpass_protobuf/credentials.pb.dart' as protobuf;
import '../types/abstracts.dart';
import '../types/connection_config.dart';
@ -13,7 +12,7 @@ import '../types/credential.dart';
class GRPCCredentialsClient implements CredentialsRepo {
static GRPCCredentialsClient _cached;
grpc.CredentialServiceClient _client;
grpc.CredentialsClient _client;
GRPCCredentialsClient(ConnectionConfig config) {
final caCert = utf8.encode(config.caCertificate);
@ -24,7 +23,7 @@ class GRPCCredentialsClient implements CredentialsRepo {
final hostname = splitHost[0];
final port = int.parse(splitHost[1]);
_client = grpc.CredentialServiceClient(ClientChannel(
_client = grpc.CredentialsClient(ClientChannel(
hostname,
port: port,
options: ChannelOptions(
@ -37,7 +36,7 @@ class GRPCCredentialsClient implements CredentialsRepo {
config == null ? _cached : _cached = GRPCCredentialsClient(config);
Stream<Metadata> getAllMetadata(String sourceHost) {
final request = grpc.GetAllMetadataRequest();
final request = grpc.SourceHostRequest();
request.sourceHost = sourceHost;
return _client.getAllMetadata(request).map<Metadata>(