ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2025-05-31 14:40:52 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Make Checkpoint classes data classes (#6342)

Browse Source 
* Make Checkpoint classes data classes

* tidy up null-checks for array equality
This commit is contained in:
Stefano Franz 2020-06-12 16:35:32 +01:00 committed by GitHub
parent 506b7609a3
commit 64f0011a62
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 84 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

92
node/src/main/kotlin/net/corda/node/services/persistence/DBCheckpointStorage.kt
View File

@ -88,7 +88,7 @@ class DBCheckpointStorage(
@Entity
@javax.persistence.Table(name = "${NODE_DATABASE_PREFIX}checkpoints")
class DBFlowCheckpoint(
data class DBFlowCheckpoint(
@Id
@Column(name = "flow_id", length = 64, nullable = false)
var flowId: String,
@ -127,7 +127,7 @@ class DBCheckpointStorage(
@Entity
@javax.persistence.Table(name = "${NODE_DATABASE_PREFIX}checkpoint_blobs")
class DBFlowCheckpointBlob(
data class DBFlowCheckpointBlob(
@Id
@Column(name = "flow_id", length = 64, nullable = false)
var flowId: String,
@ -146,11 +146,39 @@ class DBCheckpointStorage(
@Column(name = "timestamp")
var persistedInstant: Instant
)
) {
override fun equals(other: Any?): Boolean {
if (this === other) return true
if (javaClass != other?.javaClass) return false
other as DBFlowCheckpointBlob
if (flowId != other.flowId) return false
if (!checkpoint.contentEquals(other.checkpoint)) return false
if (!(flowStack ?: EMPTY_BYTE_ARRAY)!!.contentEquals(other.flowStack ?: EMPTY_BYTE_ARRAY)) {
return false
}
if (!hmac.contentEquals(other.hmac)) return false
if (persistedInstant != other.persistedInstant) return false
return true
}
override fun hashCode(): Int {
var result = flowId.hashCode()
result = 31 * result + checkpoint.contentHashCode()
result = 31 * result + (flowStack?.contentHashCode() ?: 0)
result = 31 * result + hmac.contentHashCode()
result = 31 * result + persistedInstant.hashCode()
return result
}
}
@Entity
@javax.persistence.Table(name = "${NODE_DATABASE_PREFIX}flow_results")
class DBFlowResult(
data class DBFlowResult(
@Id
@Column(name = "flow_id", length = 64, nullable = false)
var flow_id: String,
@ -161,11 +189,31 @@ class DBCheckpointStorage(
@Column(name = "timestamp")
val persistedInstant: Instant
)
) {
override fun equals(other: Any?): Boolean {
if (this === other) return true
if (javaClass != other?.javaClass) return false
other as DBFlowResult
if (flow_id != other.flow_id) return false
if (!value.contentEquals(other.value)) return false
if (persistedInstant != other.persistedInstant) return false
return true
}
override fun hashCode(): Int {
var result = flow_id.hashCode()
result = 31 * result + value.contentHashCode()
result = 31 * result + persistedInstant.hashCode()
return result
}
}
@Entity
@javax.persistence.Table(name = "${NODE_DATABASE_PREFIX}flow_exceptions")
class DBFlowException(
data class DBFlowException(
@Id
@Column(name = "flow_id", length = 64, nullable = false)
var flow_id: String,
@ -185,11 +233,39 @@ class DBCheckpointStorage(
@Column(name = "timestamp")
val persistedInstant: Instant
)
) {
override fun equals(other: Any?): Boolean {
if (this === other) return true
if (javaClass != other?.javaClass) return false
other as DBFlowException
if (flow_id != other.flow_id) return false
if (type != other.type) return false
if (message != other.message) return false
if (stackTrace != other.stackTrace) return false
if (!(value ?: EMPTY_BYTE_ARRAY)!!.contentEquals(other.value ?: EMPTY_BYTE_ARRAY)) {
return false
}
if (persistedInstant != other.persistedInstant) return false
return true
}
override fun hashCode(): Int {
var result = flow_id.hashCode()
result = 31 * result + type.hashCode()
result = 31 * result + (message?.hashCode() ?: 0)
result = 31 * result + stackTrace.hashCode()
result = 31 * result + (value?.contentHashCode() ?: 0)
result = 31 * result + persistedInstant.hashCode()
return result
}
}
@Entity
@javax.persistence.Table(name = "${NODE_DATABASE_PREFIX}flow_metadata")
class DBFlowMetadata(
data class DBFlowMetadata(
@Id
@Column(name = "flow_id", length = 64, nullable = false)
var flowId: String,