ExternalVendorCode/onefuzz
1
0
Fork 0
mirror of https://github.com/microsoft/onefuzz.git synced 2025-06-22 22:28:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Events todo (#1880)

Browse Source 
* test hooks and a bug fix

* finish events to-do

Co-authored-by: stas <statis@microsoft.com>
This commit is contained in:
Stas
2022-05-02 19:59:32 -07:00
committed by GitHub
parent 63d3ad9d90
commit e6a0906b6c
2 changed files with 11 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/ApiService/ApiService/Program.cs
View File

@ -48,6 +48,7 @@ public class Program {
return loggers; return loggers;
} }
//Move out expensive resources into separate class, and add those as Singleton //Move out expensive resources into separate class, and add those as Singleton
// ArmClient, Table Client(s), Queue Client(s), HttpClient, etc. // ArmClient, Table Client(s), Queue Client(s), HttpClient, etc.
public static void Main() { public static void Main() {

14
src/ApiService/ApiService/onefuzzlib/Events.cs
View File

@ -21,12 +21,16 @@ namespace Microsoft.OneFuzz.Service {
public class Events : IEvents { public class Events : IEvents {
private readonly IQueue _queue; private readonly IQueue _queue;
private readonly IWebhookOperations _webhook; private readonly IWebhookOperations _webhook;
private ILogTracer _log; private readonly ILogTracer _log;
private readonly IContainers _containers;
private readonly ICreds _creds;
public Events(IQueue queue, IWebhookOperations webhook, ILogTracer log) { public Events(IQueue queue, IWebhookOperations webhook, ILogTracer log, IContainers containers, ICreds creds) {
_queue = queue; _queue = queue;
_webhook = webhook; _webhook = webhook;
_log = log; _log = log;
_containers = containers;
_creds = creds;
} }
public async Async.Task QueueSignalrEvent(EventMessage eventMessage) { public async Async.Task QueueSignalrEvent(EventMessage eventMessage) {
@ -37,12 +41,14 @@ namespace Microsoft.OneFuzz.Service {
public async Async.Task SendEvent(BaseEvent anEvent) { public async Async.Task SendEvent(BaseEvent anEvent) {
var eventType = anEvent.GetEventType(); var eventType = anEvent.GetEventType();
var instanceId = await _containers.GetInstanceId();
var eventMessage = new EventMessage( var eventMessage = new EventMessage(
Guid.NewGuid(), Guid.NewGuid(),
eventType, eventType,
anEvent, anEvent,
Guid.NewGuid(), // todo instanceId,
"test" //todo _creds.GetInstanceName()
); );
await QueueSignalrEvent(eventMessage); await QueueSignalrEvent(eventMessage);
await _webhook.SendEvent(eventMessage); await _webhook.SendEvent(eventMessage);