Add CustomProperty and CustomProperties method to StreamMetadata

esdb/types.go

@@ -267,6 +267,16 @@ func (m *StreamMetadata) StreamAcl() *Acl {
 	return nil
 }
 
+// CustomProperty The custom property value for the given key.
+func (m *StreamMetadata) CustomProperty(key string) interface{} {
+	return m.customProperties[key]
+}
+
+// CustomProperties returns all custom properties.
+func (m *StreamMetadata) CustomProperties() map[string]interface{} {
+	return m.customProperties
+}
+
 // IsUserStreamAcl Checks if the ACL is set to users default.
 func (m *StreamMetadata) IsUserStreamAcl() bool {
 	acl := m.Acl()

esdb/types_test.go

@@ -74,3 +74,31 @@ func TestConsistentMetadataSerializationSystemStreamAcl(t *testing.T) {
 
 	assert.Equal(t, expected, *meta, "consistency serialization failure")
 }
+
+func TestCustomPropertyRetrievalFromStreamMetadata(t *testing.T) {
+	expected := esdb.StreamMetadata{}
+	expected.AddCustomProperty("foo", "bar")
+
+	foo := expected.CustomProperty("foo")
+
+	assert.Equal(t, "bar", foo, "custom property value mismatch")
+}
+
+func TestUnknownCustomPropertyRetrievalFromStreamMetadata(t *testing.T) {
+	expected := esdb.StreamMetadata{}
+	expected.AddCustomProperty("foo", "bar")
+
+	foo := expected.CustomProperty("foes")
+
+	assert.Empty(t, foo, "custom property value mismatch")
+}
+
+func TestGetAllCustomPropertiesFromStreamMetadata(t *testing.T) {
+	expected := esdb.StreamMetadata{}
+	expected.AddCustomProperty("foo", 123)
+	expected.AddCustomProperty("foes", "baz")
+
+	props := expected.CustomProperties()
+
+	assert.Equal(t, map[string]interface{}{"foo": 123, "foes": "baz"}, props, "custom properties mismatch")
+}