Top Inners Fields Constructors Methods
org.bouncycastle.mls.client

public Class MLSClientImpl

extends MLSClientImplBase
Class Inheritance
Imports
java.io.IOException, java.security.SecureRandom, java.util.ArrayList, .Arrays, .HashMap, .List, .Map, com.google.protobuf.ByteString, .MessageOrBuilder, io.grpc.Status, .StatusException, io.grpc.stub.StreamObserver, mls_client.MLSClientGrpc, .MlsClient, org.bouncycastle.crypto.AsymmetricCipherKeyPair, org.bouncycastle.mls.TreeKEM.LeafIndex, .LeafNode, .LifeTime, .TreeKEMPublicKey, org.bouncycastle.mls.codec.Capabilities, .Credential, .Extension, .ExtensionType, .ExternalSender, .GroupInfo, .KeyPackage, .MLSInputStream, .MLSMessage, .MLSOutputStream, .PreSharedKeyID, .Proposal, .ProtocolVersion, .ResumptionPSKUsage, .Welcome, .WireFormat, org.bouncycastle.mls.crypto.MlsCipherSuite, .Secret, org.bouncycastle.mls.protocol.Group, org.bouncycastle.util.Pack

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv class
MLSClientImpl.CachedGroup

pack-priv class
MLSClientImpl.CachedJoin

pack-priv class
MLSClientImpl.CachedReinit

public static interface
MLSClientImpl.Function

public static interface
MLSClientImpl.FunctionWithState

Field Summary

Modifier and TypeField and Description
pack-priv Map<Integer, MLSClientImpl.CachedGroup>
groupCache

pack-priv Map<Integer, MLSClientImpl.CachedJoin>
joinCache

pack-priv Map<Integer, MLSClientImpl.CachedReinit>
reinitCache

pack-priv Map<Integer, byte[]>
signerCache

Constructor Summary

AccessConstructor and Description
public
MLSClientImpl()

Method Summary

Modifier and TypeMethod and Description
public void
addExternalSigner(MlsClient.AddExternalSignerRequest request, StreamObserver<MlsClient.ProposalResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.addExternalSigner.

private void
addExternalSignerImpl(MLSClientImpl.CachedGroup entry, MlsClient.AddExternalSignerRequest request, StreamObserver<MlsClient.ProposalResponse> responseObserver)

public void
addProposal(MlsClient.AddProposalRequest request, StreamObserver<MlsClient.ProposalResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.addProposal.

private void
addProposalImpl(MLSClientImpl.CachedGroup entry, MlsClient.AddProposalRequest request, StreamObserver<MlsClient.ProposalResponse> responseObserver)

private static <T> void
catchWrap(MLSClientImpl.Function f, StreamObserver<T> observer)

public void
commit(MlsClient.CommitRequest request, StreamObserver<MlsClient.CommitResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.commit.

private void
commitImpl(MLSClientImpl.CachedGroup entry, MlsClient.CommitRequest request, StreamObserver<MlsClient.CommitResponse> responseObserver)

public void
createBranch(MlsClient.CreateBranchRequest request, StreamObserver<MlsClient.CreateSubgroupResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.createBranch.

Subgroup Branching
private void
createBranchImpl(MLSClientImpl.CachedGroup entry, MlsClient.CreateBranchRequest request, StreamObserver<MlsClient.CreateSubgroupResponse> responseObserver)

Subgroup Branching
public void
createExternalSigner(MlsClient.CreateExternalSignerRequest request, StreamObserver<MlsClient.CreateExternalSignerResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.createExternalSigner.

private void
createExternalSignerImpl(MlsClient.CreateExternalSignerRequest request, StreamObserver<MlsClient.CreateExternalSignerResponse> responseObserver)

public void
createGroup(MlsClient.CreateGroupRequest request, StreamObserver<MlsClient.CreateGroupResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.createGroup.

Ways to become a member of a group
public void
createGroupImpl(MlsClient.CreateGroupRequest request, StreamObserver<MlsClient.CreateGroupResponse> responseObserver)

Ways to become a member of a group
public void
createKeyPackage(MlsClient.CreateKeyPackageRequest request, StreamObserver<MlsClient.CreateKeyPackageResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.createKeyPackage.

private void
createKeyPackageImpl(MlsClient.CreateKeyPackageRequest request, StreamObserver<MlsClient.CreateKeyPackageResponse> responseObserver)

public void
export(MlsClient.ExportRequest request, StreamObserver<MlsClient.ExportResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.export.

private void
exportImpl(MLSClientImpl.CachedGroup entry, MlsClient.ExportRequest request, StreamObserver<MlsClient.ExportResponse> responseObserver)

public void
externalJoin(MlsClient.ExternalJoinRequest request, StreamObserver<MlsClient.ExternalJoinResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.externalJoin.

private void
externalJoinImpl(MlsClient.ExternalJoinRequest request, StreamObserver<MlsClient.ExternalJoinResponse> responseObserver)

public void
externalPSKProposal(MlsClient.ExternalPSKProposalRequest request, StreamObserver<MlsClient.ProposalResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.externalPSKProposal.

private void
externalPSKProposalImpl(MLSClientImpl.CachedGroup entry, MlsClient.ExternalPSKProposalRequest request, StreamObserver<MlsClient.ProposalResponse> responseObserver)

public void
externalSignerProposal(MlsClient.ExternalSignerProposalRequest request, StreamObserver<MlsClient.ProposalResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.externalSignerProposal.

private void
externalSignerProposalImpl(MlsClient.ExternalSignerProposalRequest request, StreamObserver<MlsClient.ProposalResponse> responseObserver)

private LeafIndex
findMember(TreeKEMPublicKey tree, byte[] id)

private MLSClientImpl.CachedGroup
findState(byte[] groupID, long epoch)

public void
free(MlsClient.FreeRequest request, StreamObserver<MlsClient.FreeResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.free.

Cleanup
private void
freeImpl(MlsClient.FreeRequest request, StreamObserver<MlsClient.FreeResponse> responseObserver)

Cleanup
private static String
getCallerMethodName()

public void
groupContextExtensionsProposal(MlsClient.GroupContextExtensionsProposalRequest request, StreamObserver<MlsClient.ProposalResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.groupContextExtensionsProposal.

private void
groupContextExtensionsProposalImpl(MLSClientImpl.CachedGroup entry, MlsClient.GroupContextExtensionsProposalRequest request, StreamObserver<MlsClient.ProposalResponse> responseObserver)

public void
groupInfo(MlsClient.GroupInfoRequest request, StreamObserver<MlsClient.GroupInfoResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.groupInfo.

Operations using a group state
private void
groupInfoImpl(MLSClientImpl.CachedGroup entry, MlsClient.GroupInfoRequest request, StreamObserver<MlsClient.GroupInfoResponse> responseObserver)

Operations using a group state
public void
handleBranch(MlsClient.HandleBranchRequest request, StreamObserver<MlsClient.HandleBranchResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.handleBranch.

private void
handleBranchImpl(MLSClientImpl.CachedGroup entry, MlsClient.HandleBranchRequest request, StreamObserver<MlsClient.HandleBranchResponse> responseObserver)

public void
handleCommit(MlsClient.HandleCommitRequest request, StreamObserver<MlsClient.HandleCommitResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.handleCommit.

private void
handleCommitImpl(MLSClientImpl.CachedGroup entry, MlsClient.HandleCommitRequest request, StreamObserver<MlsClient.HandleCommitResponse> responseObserver)

public void
handlePendingCommit(MlsClient.HandlePendingCommitRequest request, StreamObserver<MlsClient.HandleCommitResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.handlePendingCommit.

private void
handlePendingCommitImpl(MLSClientImpl.CachedGroup entry, MlsClient.HandlePendingCommitRequest request, StreamObserver<MlsClient.HandleCommitResponse> responseObserver)

public void
handlePendingReInitCommit(MlsClient.HandlePendingCommitRequest request, StreamObserver<MlsClient.HandleReInitCommitResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.handlePendingReInitCommit.

private void
handlePendingReInitCommitImpl(MLSClientImpl.CachedGroup entry, MlsClient.HandlePendingCommitRequest request, StreamObserver<MlsClient.HandleReInitCommitResponse> responseObserver)

public void
handleReInitCommit(MlsClient.HandleCommitRequest request, StreamObserver<MlsClient.HandleReInitCommitResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.handleReInitCommit.

private void
handleReInitCommitImpl(MLSClientImpl.CachedGroup entry, MlsClient.HandleCommitRequest request, StreamObserver<MlsClient.HandleReInitCommitResponse> responseObserver)

public void
handleReInitWelcome(MlsClient.HandleReInitWelcomeRequest request, StreamObserver<MlsClient.JoinGroupResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.handleReInitWelcome.

private void
handleReInitWelcomeImpl(MlsClient.HandleReInitWelcomeRequest request, StreamObserver<MlsClient.JoinGroupResponse> responseObserver)

public void
joinGroup(MlsClient.JoinGroupRequest request, StreamObserver<MlsClient.JoinGroupResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.joinGroup.

private void
joinGroupImpl(MlsClient.JoinGroupRequest request, StreamObserver<MlsClient.JoinGroupResponse> responseObserver)

private MLSClientImpl.CachedGroup
loadGroup(int stateID)

private MLSClientImpl.CachedJoin
loadJoin(int joinID)

private MLSClientImpl.CachedReinit
loadReinit(int reinitID)

private byte[]
loadSigner(int signerID)

public void
name(MlsClient.NameRequest request, StreamObserver<MlsClient.NameResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.name.

The human-readable name of the stack
private void
nameImpl(MlsClient.NameRequest request, StreamObserver<MlsClient.NameResponse> responseObserver)

The human-readable name of the stack
private KeyPackageWithSecrets
newKeyPackage(MlsCipherSuite suite, byte[] identity)

public void
newMemberAddProposal(MlsClient.NewMemberAddProposalRequest request, StreamObserver<MlsClient.NewMemberAddProposalResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.newMemberAddProposal.

External proposals
private void
newMemberAddProposalImpl(MlsClient.NewMemberAddProposalRequest request, StreamObserver<MlsClient.NewMemberAddProposalResponse> responseObserver)

External proposals
private Proposal
proposalFromDescription(MlsCipherSuite suite, byte[] groupID, TreeKEMPublicKey tree, MlsClient.ProposalDescription desc)

public void
protect(MlsClient.ProtectRequest request, StreamObserver<MlsClient.ProtectResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.protect.

private void
protectImpl(MLSClientImpl.CachedGroup entry, MlsClient.ProtectRequest request, StreamObserver<MlsClient.ProtectResponse> responseObserver)

public void
reInitCommit(MlsClient.CommitRequest request, StreamObserver<MlsClient.CommitResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.reInitCommit.

private void
reInitCommitImpl(MLSClientImpl.CachedGroup entry, MlsClient.CommitRequest request, StreamObserver<MlsClient.CommitResponse> responseObserver)

public void
reInitProposal(MlsClient.ReInitProposalRequest request, StreamObserver<MlsClient.ProposalResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.reInitProposal.

Reinitialization
private void
reInitProposalImpl(MLSClientImpl.CachedGroup entry, MlsClient.ReInitProposalRequest request, StreamObserver<MlsClient.ProposalResponse> responseObserver)

Reinitialization
public void
reInitWelcome(MlsClient.ReInitWelcomeRequest request, StreamObserver<MlsClient.CreateSubgroupResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.reInitWelcome.

private void
reInitWelcomeImpl(MlsClient.ReInitWelcomeRequest request, StreamObserver<MlsClient.CreateSubgroupResponse> responseObserver)

private void
removeGroup(int stateID)

public void
removeProposal(MlsClient.RemoveProposalRequest request, StreamObserver<MlsClient.ProposalResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.removeProposal.

private void
removeProposalImpl(MLSClientImpl.CachedGroup entry, MlsClient.RemoveProposalRequest request, StreamObserver<MlsClient.ProposalResponse> responseObserver)

public void
resumptionPSKProposal(MlsClient.ResumptionPSKProposalRequest request, StreamObserver<MlsClient.ProposalResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.resumptionPSKProposal.

private void
resumptionPSKProposalImpl(MLSClientImpl.CachedGroup entry, MlsClient.ResumptionPSKProposalRequest request, StreamObserver<MlsClient.ProposalResponse> responseObserver)

public void
stateAuth(MlsClient.StateAuthRequest request, StreamObserver<MlsClient.StateAuthResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.stateAuth.

private void
stateAuthImpl(MLSClientImpl.CachedGroup entry, MlsClient.StateAuthRequest request, StreamObserver<MlsClient.StateAuthResponse> responseObserver)

private <T> void
stateWrap(MLSClientImpl.FunctionWithState f, MessageOrBuilder request, StreamObserver<T> observer)

private int
storeGroup(Group group, boolean encryptHandshake)

private int
storeJoin(KeyPackageWithSecrets kpSecrets)

public void
storePSK(MlsClient.StorePSKRequest request, StreamObserver<MlsClient.StorePSKResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.storePSK.

private void
storePSKImpl(MlsClient.StorePSKRequest request, StreamObserver<MlsClient.StorePSKResponse> responseObserver)

private int
storeReinit(KeyPackageWithSecrets kpSk, Group.Tombstone tombstone, boolean encryptHandshake)

private int
storeSigner(byte[] sigPriv)

public void
supportedCiphersuites(MlsClient.SupportedCiphersuitesRequest request, StreamObserver<MlsClient.SupportedCiphersuitesResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.supportedCiphersuites.

List of supported ciphersuites
private void
supportedCiphersuitesImpl(MlsClient.SupportedCiphersuitesRequest request, StreamObserver<MlsClient.SupportedCiphersuitesResponse> responseObserver)

List of supported ciphersuites
public void
unprotect(MlsClient.UnprotectRequest request, StreamObserver<MlsClient.UnprotectResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.unprotect.

private void
unprotectImpl(MLSClientImpl.CachedGroup entry, MlsClient.UnprotectRequest request, StreamObserver<MlsClient.UnprotectResponse> responseObserver)

public void
updateProposal(MlsClient.UpdateProposalRequest request, StreamObserver<MlsClient.ProposalResponse> responseObserver)

Overrides default mls_client.MLSClientGrpc.AsyncService.updateProposal.

private void
updateProposalImpl(MLSClientImpl.CachedGroup entry, MlsClient.UpdateProposalRequest request, StreamObserver<MlsClient.ProposalResponse> responseObserver)

Inherited from mls_client.MLSClientGrpc.MLSClientImplBase:
bindService