Skip to content

Commit c099e48

Browse files
refactor: replace HabState with Identifier in various classes and methods for consistency
1 parent 2b4451d commit c099e48

29 files changed

+303
-398
lines changed

src/main/java/org/cardanofoundation/signify/app/Contacting.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919
import java.util.Optional;
2020
import com.fasterxml.jackson.annotation.JsonAnySetter;
2121
import java.util.concurrent.ExecutionException;
22+
import org.cardanofoundation.signify.generated.keria.model.Identifier;
2223

2324
public class Contacting {
2425

@@ -66,7 +67,7 @@ public Challenge generate() throws LibsodiumException, IOException, InterruptedE
6667
* @throws Exception if the fetch operation fails
6768
*/
6869
public Object respond(String name, String recipient, List<String> words) throws IOException, InterruptedException, DigestException, ExecutionException, LibsodiumException {
69-
States.HabState hab = this.client.identifiers().get(name)
70+
Identifier hab = this.client.identifiers().get(name)
7071
.orElseThrow(() -> new IllegalArgumentException("Identifier not found: " + name));
7172
Exchanging.Exchanges exchanges = this.client.exchanges();
7273

src/main/java/org/cardanofoundation/signify/app/Exchanging.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919
import java.security.DigestException;
2020
import java.util.*;
2121
import java.util.concurrent.ExecutionException;
22+
import org.cardanofoundation.signify.generated.keria.model.Identifier;
2223

2324
public class Exchanging {
2425
@Getter
@@ -46,7 +47,7 @@ public Exchanges(SignifyClient client) {
4647
* @return array containing [Serder, signatures, attachment]
4748
*/
4849
public ExchangeMessageResult createExchangeMessage(
49-
HabState sender,
50+
Identifier sender,
5051
String route,
5152
Map<String, Object> payload,
5253
Map<String, List<Object>> embeds,
@@ -89,7 +90,7 @@ public ExchangeMessageResult createExchangeMessage(
8990
public Object send(
9091
String name,
9192
String topic,
92-
HabState sender,
93+
Identifier sender,
9394
String route,
9495
Map<String, Object> payload,
9596
Map<String, List<Object>> embeds,

src/main/java/org/cardanofoundation/signify/app/aiding/CreateIdentifierArgs.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@
66
import org.cardanofoundation.signify.cesr.Salter.Tier;
77
import org.cardanofoundation.signify.core.Manager.Algos;
88
import org.cardanofoundation.signify.core.States.HabState;
9+
import org.cardanofoundation.signify.generated.keria.model.Identifier;
910

1011
@Getter
1112
@Setter
@@ -28,7 +29,7 @@ public class CreateIdentifierArgs {
2829
private List<Object> rstates;
2930
private List<Object> prxs;
3031
private List<Object> nxts;
31-
private HabState mhab;
32+
private Identifier mhab;
3233
private List<String> keys;
3334
private List<String> ndigs;
3435
private String bran;

src/main/java/org/cardanofoundation/signify/app/aiding/Identifier.java renamed to src/main/java/org/cardanofoundation/signify/app/aiding/IdentifierController.java

Lines changed: 18 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -28,19 +28,21 @@
2828
import java.security.DigestException;
2929
import java.util.*;
3030
import java.util.concurrent.ExecutionException;
31+
import org.cardanofoundation.signify.generated.keria.model.Identifier;
32+
import org.cardanofoundation.signify.generated.keria.model.KeyStateRecord;
3133

3234
import static org.cardanofoundation.signify.cesr.util.CoreUtil.Versionage;
3335
import static org.cardanofoundation.signify.core.Httping.parseRangeHeaders;
3436

35-
public class Identifier {
37+
public class IdentifierController {
3638
public final IdentifierDeps client;
3739

3840
/**
3941
* Identifier
4042
*
4143
* @param client the client dependencies
4244
*/
43-
public Identifier(IdentifierDeps client) {
45+
public IdentifierController(IdentifierDeps client) {
4446
this.client = client;
4547
}
4648

@@ -69,7 +71,7 @@ public IdentifierListResponse list(Integer start, Integer end) throws Interrupte
6971
range.start(),
7072
range.end(),
7173
range.total(),
72-
Arrays.asList(GeneratedModelMapper.read(response.body(), org.cardanofoundation.signify.generated.keria.model.Identifier[].class))
74+
Arrays.asList(Utils.fromJson(response.body(), Identifier[].class))
7375
);
7476
}
7577

@@ -87,7 +89,7 @@ public IdentifierListResponse list(Integer start) throws IOException, Interrupte
8789
* @param name Prefix or alias of the identifier
8890
* @return An Optional containing the HabState if found, or empty if not found
8991
*/
90-
public Optional<States.HabState> get(String name) throws InterruptedException, IOException, LibsodiumException {
92+
public Optional<Identifier> get(String name) throws InterruptedException, IOException, LibsodiumException {
9193
final String path = "/identifiers/" + URI.create(name).toASCIIString();
9294
final String method = "GET";
9395

@@ -97,7 +99,7 @@ public Optional<States.HabState> get(String name) throws InterruptedException, I
9799
return Optional.empty();
98100
}
99101

100-
return Optional.of(Utils.fromJson(response.body(), States.HabState.class));
102+
return Optional.of(Utils.fromJson(response.body(), Identifier.class));
101103
}
102104

103105
/**
@@ -107,7 +109,7 @@ public Optional<States.HabState> get(String name) throws InterruptedException, I
107109
* @param info Information to update for the given identifier
108110
* @return A HabState to the identifier information after updating
109111
*/
110-
public States.HabState update(String name, IdentifierInfo info) throws InterruptedException, IOException, LibsodiumException {
112+
public Identifier update(String name, IdentifierInfo info) throws InterruptedException, IOException, LibsodiumException {
111113
final String path = "/identifiers/" + name;
112114
final String method = "PUT";
113115

@@ -116,7 +118,7 @@ public States.HabState update(String name, IdentifierInfo info) throws Interrupt
116118
method,
117119
IdentifierPayloadMapper.buildUpdateNamePayload(info.getName())
118120
);
119-
return GeneratedModelMapper.read(response.body(), States.HabState.class);
121+
return Utils.fromJson(response.body(), Identifier.class);
120122
}
121123

122124
/**
@@ -289,7 +291,7 @@ public EventResult create(String name, CreateIdentifierArgs kargs) throws Interr
289291
* @throws LibsodiumException if there is an error in the cryptographic operations
290292
*/
291293
public EventResult addEndRole(String name, String role, String eid, String stamp) throws InterruptedException, DigestException, IOException, LibsodiumException {
292-
States.HabState hab = this.get(name)
294+
Identifier hab = this.get(name)
293295
.orElseThrow(() -> new IllegalArgumentException("Identifier not found: " + name));
294296
String pre = hab.getPrefix();
295297

@@ -340,11 +342,11 @@ public EventResult interact(String name, Object data) throws InterruptedExceptio
340342
}
341343

342344
public InteractionResponse createInteract(String name, Object data) throws InterruptedException, DigestException, IOException, LibsodiumException {
343-
States.HabState hab = this.get(name)
345+
Identifier hab = this.get(name)
344346
.orElseThrow(() -> new IllegalArgumentException("Identifier not found: " + name));
345347
String pre = hab.getPrefix();
346348

347-
States.State state = hab.getState();
349+
KeyStateRecord state = hab.getState();
348350
int sn = Integer.parseInt(state.getS(), 16);
349351
String dig = state.getD();
350352

@@ -379,12 +381,12 @@ public EventResult rotate(String name, RotateIdentifierArgs kargs) throws Interr
379381
String ncode = kargs.getNcode() != null ? kargs.getNcode() : MatterCodex.Ed25519_Seed.getValue();
380382
int ncount = kargs.getNcount() != null ? kargs.getNcount() : 1;
381383

382-
States.HabState hab = this.get(name)
384+
Identifier hab = this.get(name)
383385
.orElseThrow(() -> new IllegalArgumentException("Identifier not found: " + name));
384386
String pre = hab.getPrefix();
385387
boolean delegated = !hab.getState().getDi().isEmpty();
386388

387-
States.State state = hab.getState();
389+
KeyStateRecord state = hab.getState();
388390
int count = state.getK().size();
389391
String dig = state.getD();
390392
int ridx = Integer.parseInt(state.getS(), 16) + 1;
@@ -410,8 +412,8 @@ public EventResult rotate(String name, RotateIdentifierArgs kargs) throws Interr
410412
// Create new keys for next digests
411413
List<String> ncodes = kargs.getNcodes() != null ? kargs.getNcodes() : Collections.nCopies(ncount, ncode);
412414

413-
List<States.State> states = kargs.getStates() == null ? new ArrayList<>() : kargs.getStates();
414-
List<States.State> rstates = kargs.getStates() == null ? new ArrayList<>() : kargs.getRstates();
415+
List<KeyStateRecord> states = kargs.getStates() == null ? new ArrayList<>() : kargs.getStates();
416+
List<KeyStateRecord> rstates = kargs.getStates() == null ? new ArrayList<>() : kargs.getRstates();
415417
KeeperResult keeperResult = keeper.rotate(
416418
ncodes,
417419
transferable,
@@ -449,8 +451,8 @@ public EventResult rotate(String name, RotateIdentifierArgs kargs) throws Interr
449451
Map<String, Object> jsondata = new LinkedHashMap<>();
450452
jsondata.put("rot", serder.getKed());
451453
jsondata.put("sigs", sigs);
452-
jsondata.put("smids", !states.isEmpty() ? states.stream().map(States.State::getI).toList() : null);
453-
jsondata.put("rmids", !rstates.isEmpty() ? rstates.stream().map(States.State::getI).toList() : null);
454+
jsondata.put("smids", !states.isEmpty() ? states.stream().map(KeyStateRecord::getI).toList() : null);
455+
jsondata.put("rmids", !rstates.isEmpty() ? rstates.stream().map(KeyStateRecord::getI).toList() : null);
454456
jsondata.put(keeper.getAlgo().toString(), keeper.getParams().toMap());
455457

456458
HttpResponse<String> res = this.client.fetch(

src/main/java/org/cardanofoundation/signify/app/aiding/IdentifierModelConverter.java

Lines changed: 0 additions & 124 deletions
This file was deleted.

src/main/java/org/cardanofoundation/signify/app/aiding/RotateIdentifierArgs.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@
66
import org.cardanofoundation.signify.core.States;
77

88
import java.util.List;
9+
import org.cardanofoundation.signify.generated.keria.model.KeyStateRecord;
910

1011
@Builder
1112
@Getter
@@ -20,6 +21,6 @@ public class RotateIdentifierArgs {
2021
private String ncode;
2122
private Integer ncount;
2223
private List<String> ncodes;
23-
private List<States.State> states;
24-
private List<States.State> rstates;
24+
private List<KeyStateRecord> states;
25+
private List<KeyStateRecord> rstates;
2526
}

src/main/java/org/cardanofoundation/signify/app/clienting/SignifyClient.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616
import org.cardanofoundation.signify.app.Exchanging.Exchanges;
1717
import org.cardanofoundation.signify.app.Grouping.Groups;
1818
import org.cardanofoundation.signify.app.Notifying.Notifications;
19-
import org.cardanofoundation.signify.app.aiding.Identifier;
19+
import org.cardanofoundation.signify.app.aiding.IdentifierController;
2020
import org.cardanofoundation.signify.app.clienting.exception.HeaderVerificationException;
2121
import org.cardanofoundation.signify.app.clienting.exception.UnexpectedResponseStatusException;
2222
import org.cardanofoundation.signify.app.coring.KeyStates;
@@ -61,7 +61,7 @@ public class SignifyClient implements IdentifierDeps, OperationsDeps {
6161
private String bootUrl;
6262
private List<ExternalModule> externalModules;
6363

64-
private Identifier identifierInstance = new Identifier(this);
64+
private IdentifierController identifierControllerInstance = new IdentifierController(this);
6565
private Oobis oobisInstance = new Oobis(this);
6666
private Operations operationsInstance = new Operations(this);
6767
private KeyEvents keyEventsInstance = new KeyEvents(this);
@@ -374,8 +374,8 @@ public void approveDelegation() throws DigestException, IOException, Interrupted
374374
*
375375
* @return {Identifier}
376376
*/
377-
public Identifier identifiers() {
378-
return identifierInstance;
377+
public IdentifierController identifiers() {
378+
return identifierControllerInstance;
379379
}
380380

381381
/**

src/main/java/org/cardanofoundation/signify/app/credentialing/credentials/Credentials.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818
import java.net.http.HttpResponse;
1919
import java.security.DigestException;
2020
import java.util.*;
21+
import org.cardanofoundation.signify.generated.keria.model.Identifier;
2122

2223
public class Credentials {
2324

@@ -106,7 +107,7 @@ public Optional<Object> state(String ri, String said) throws IOException, Interr
106107
* Issue a credential
107108
*/
108109
public IssueCredentialResult issue(String name, CredentialData args) throws IOException, InterruptedException, DigestException, LibsodiumException {
109-
final States.HabState hab = this.client.identifiers().get(name)
110+
final Identifier hab = this.client.identifiers().get(name)
110111
.orElseThrow(() -> new IllegalArgumentException("Identifier not found: " + name));
111112

112113
final boolean estOnly = hab.getState().getC() != null && hab.getState().getC().contains("EO");
@@ -189,7 +190,7 @@ public IssueCredentialResult issue(String name, CredentialData args) throws IOEx
189190
* @return A promise to the long-running operation
190191
*/
191192
public RevokeCredentialResult revoke(String name, String said, String datetime) throws IOException, InterruptedException, DigestException, LibsodiumException {
192-
final States.HabState hab = this.client.identifiers().get(name)
193+
final Identifier hab = this.client.identifiers().get(name)
193194
.orElseThrow(() -> new IllegalArgumentException("Identifier not found: " + name));
194195
final String pre = hab.getPrefix();
195196

0 commit comments

Comments
 (0)