Skip to content

Add ProtoBuf message definitions and update MessageMap registration #14

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
tiksn merged 1 commit into from
Feb 1, 2026
Merged

Add ProtoBuf message definitions and update MessageMap registration #14

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
18 changes: 10 additions & 8 deletions Source/Messaging/MessageMap.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,5 +1,7 @@
namespace Fossa.Messaging;

using Fossa.Messaging.Messages.Events;

/// <summary>
/// Provides a mapping between message types and their corresponding integer identifiers for message serialization and
/// deserialization.
Expand Down Expand Up @@ -48,13 +50,13 @@ private static void RegisterMessageType<TKey>(int value, ref BiMap<ComparableTyp

private static void RegisterMessageTypes(ref BiMap<ComparableType, int> messageTypeBiMap)
{
RegisterMessageType<CompanyChanged>(64169988, ref messageTypeBiMap);
RegisterMessageType<CompanyDeleted>(64169993, ref messageTypeBiMap);
RegisterMessageType<EmployeeChanged>(64171400, ref messageTypeBiMap);
RegisterMessageType<EmployeeDeleted>(64171404, ref messageTypeBiMap);
RegisterMessageType<BranchChanged>(64171407, ref messageTypeBiMap);
RegisterMessageType<BranchDeleted>(64171411, ref messageTypeBiMap);
RegisterMessageType<DepartmentChanged>(64171414, ref messageTypeBiMap);
RegisterMessageType<DepartmentDeleted>(64171418, ref messageTypeBiMap);
RegisterMessageType<CompanyChangedProtoEvent>(64169988, ref messageTypeBiMap);
RegisterMessageType<CompanyDeletedProtoEvent>(64169993, ref messageTypeBiMap);
RegisterMessageType<EmployeeChangedProtoEvent>(64171400, ref messageTypeBiMap);
RegisterMessageType<EmployeeDeletedProtoEvent>(64171404, ref messageTypeBiMap);
RegisterMessageType<BranchChangedProtoEvent>(64171407, ref messageTypeBiMap);
RegisterMessageType<BranchDeletedProtoEvent>(64171411, ref messageTypeBiMap);
RegisterMessageType<DepartmentChangedProtoEvent>(64171414, ref messageTypeBiMap);
RegisterMessageType<DepartmentDeletedProtoEvent>(64171418, ref messageTypeBiMap);
}
}
20 changes: 10 additions & 10 deletions Source/Messaging/schema.proto → Source/Messaging/Messages/Events.proto
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,16 +1,16 @@
syntax = "proto3";

package Fossa.Messaging;
package Fossa.Messaging.Messages.Events;

option csharp_namespace = "Fossa.Messaging";
option csharp_namespace = "Fossa.Messaging.Messages.Events";

message CompanyChanged {
message CompanyChangedProtoEvent {
int64 CompanyId = 1;
string Name = 2;
string CountryCodes = 3;
}

message CompanyDeleted {
message CompanyDeletedProtoEvent {
int64 CompanyId = 1;
}

Expand All @@ -23,19 +23,19 @@ message Address {
string Subdivision = 6;
}

message BranchChanged {
message BranchChangedProtoEvent {
int64 BranchId = 1;
int64 CompanyId = 2;
string Name = 3;
Address Address = 4;
string TimeZoneId = 5;
}

message BranchDeleted {
message BranchDeletedProtoEvent {
int64 BranchId = 1;
}

message EmployeeChanged {
message EmployeeChangedProtoEvent {
int64 EmployeeId = 1;
int64 CompanyId = 2;
string FirstName = 3;
Expand All @@ -47,18 +47,18 @@ message EmployeeChanged {
int64 ReportsToId = 9;
}

message EmployeeDeleted {
message EmployeeDeletedProtoEvent {
int64 EmployeeId = 1;
}

message DepartmentChanged {
message DepartmentChangedProtoEvent {
int64 DepartmentId = 1;
int64 CompanyId = 2;
string Name = 3;
int64 ManagerId = 4;
int64 ParentDepartmentId = 5;
}

message DepartmentDeleted {
message DepartmentDeletedProtoEvent {
int64 DepartmentId = 1;
}
2 changes: 1 addition & 1 deletion Source/Messaging/Messaging.csproj
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -21,6 +21,6 @@
</ItemGroup>

<ItemGroup>
<Protobuf Include="schema.proto" GrpcServices="None" />
<Protobuf Include="Messages\Events.proto" GrpcServices="None" />
</ItemGroup>
</Project>
7 changes: 3 additions & 4 deletions Tests/.runsettings
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,9 +6,8 @@
<Configuration>
<Format>cobertura</Format>
<Exclude>
[Fossa.Messaging]*Schema*;
[Fossa.Messaging]*Changed;
[Fossa.Messaging]*Deleted;
[Fossa.Messaging.Messages.Events]*Events*;
[Fossa.Messaging.Messages.Events]*ProtoEvent*;
[Fossa.Messaging.Test]*
</Exclude>
<ExcludeByAttribute>
Expand All @@ -17,7 +16,7 @@
System.Diagnostics.DebuggerNonUserCodeAttribute
</ExcludeByAttribute>
<ExcludeByFile>
**/Schema.cs
**/Messages/Events.cs
</ExcludeByFile>
</Configuration>
</DataCollector>
Expand Down
21 changes: 11 additions & 10 deletions Tests/Messaging.Test/MessageMapTests.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
namespace Fossa.Messaging.Test;

using System.Collections.Generic;
using Fossa.Messaging.Messages.Events;

public class MessageMapTests
{
Expand All @@ -10,7 +11,7 @@ public void GetMessageType_WithRegisteredId_ShouldReturnCorrectType()
{
// Arrange
MessageMap messageMap = new();
var expectedType = typeof(CompanyChanged);
var expectedType = typeof(CompanyChangedProtoEvent);
const int messageId = 64169988;

// Act
Expand All @@ -36,7 +37,7 @@ public void GetMessageTypeID_WithRegisteredType_ShouldReturnCorrectId()
{
// Arrange
MessageMap messageMap = new();
var messageType = typeof(CompanyChanged);
var messageType = typeof(CompanyChangedProtoEvent);
const int expectedId = 64169988;

// Act
Expand All @@ -58,14 +59,14 @@ public void GetMessageTypeID_WithUnregisteredType_ShouldThrowKeyNotFoundExceptio
}

[Theory]
[InlineData(typeof(CompanyChanged), 64169988)]
[InlineData(typeof(CompanyDeleted), 64169993)]
[InlineData(typeof(EmployeeChanged), 64171400)]
[InlineData(typeof(EmployeeDeleted), 64171404)]
[InlineData(typeof(BranchChanged), 64171407)]
[InlineData(typeof(BranchDeleted), 64171411)]
[InlineData(typeof(DepartmentChanged), 64171414)]
[InlineData(typeof(DepartmentDeleted), 64171418)]
[InlineData(typeof(CompanyChangedProtoEvent), 64169988)]
[InlineData(typeof(CompanyDeletedProtoEvent), 64169993)]
[InlineData(typeof(EmployeeChangedProtoEvent), 64171400)]
[InlineData(typeof(EmployeeDeletedProtoEvent), 64171404)]
[InlineData(typeof(BranchChangedProtoEvent), 64171407)]
[InlineData(typeof(BranchDeletedProtoEvent), 64171411)]
[InlineData(typeof(DepartmentChangedProtoEvent), 64171414)]
[InlineData(typeof(DepartmentDeletedProtoEvent), 64171418)]
public void RegisterMessageTypes_ShouldRegisterAllTypes(Type messageType, int expectedId)
{
// Arrange
Expand Down
Loading