Skip to content

54 feat getoutput #70

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
wireless90 merged 2 commits into from
Oct 9, 2022
Merged

54 feat getoutput #70

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
574a9a0
Create OutputFilterOptions.cs
wireless90 Oct 9, 2022
5079662
Added GetOutputs feat
wireless90 Oct 9, 2022
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
7 changes: 7 additions & 0 deletions csharp/IotaWalletNet/IotaWalletNet.Application/Account.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -5,10 +5,12 @@
using IotaWalletNet.Application.AccountContext.Commands.SyncAccount;
using IotaWalletNet.Application.AccountContext.Queries.GetAddresses;
using IotaWalletNet.Application.AccountContext.Queries.GetBalance;
using IotaWalletNet.Application.AccountContext.Queries.GetOutputs;
using IotaWalletNet.Application.Common.Interfaces;
using IotaWalletNet.Domain.Common.Models.Address;
using IotaWalletNet.Domain.Common.Models.Network;
using IotaWalletNet.Domain.Common.Models.Nft;
using IotaWalletNet.Domain.Common.Models.Output;
using IotaWalletNet.Domain.PlatformInvoke;
using MediatR;
using static IotaWalletNet.Application.AccountContext.Commands.SyncAccount.SyncAccountCommandHandler;
Expand All @@ -30,6 +32,11 @@ public Account(IMediator mediator, string username, IWallet wallet)
public string Username { get; }
public IWallet Wallet { get; }

public async Task<GetOutputsResponse> GetOutputs(OutputFilterOptions? outputFilterOptions=null)
{
return await _mediator.Send(new GetOutputsQuery(Username, this, outputFilterOptions));
}

public async Task<GenerateAddressesResponse> GenerateAddressesAsync(uint numberOfAddresses, NetworkType networkType)
{
return await _mediator.Send(new GenerateAddressesCommand(this, networkType, Username, numberOfAddresses));
Expand Down
21 changes: 21 additions & 0 deletions ...aWalletNet/IotaWalletNet.Application/AccountContext/Queries/GetOutputs/GetOutputsQuery.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,21 @@
using IotaWalletNet.Application.Common.Interfaces;
using IotaWalletNet.Domain.Common.Models.Output;
using MediatR;

namespace IotaWalletNet.Application.AccountContext.Queries.GetOutputs
{
public class GetOutputsQuery : IRequest<GetOutputsResponse>
{
public string Username { get; set; }

public OutputFilterOptions FilterOptions { get; set; }

public IAccount Account{ get; set; }
public GetOutputsQuery(string username, IAccount account, OutputFilterOptions? outputFilterOptions=null)
{
Username = username;
Account = account;
FilterOptions = outputFilterOptions ?? new OutputFilterOptions();
}
}
}
24 changes: 24 additions & 0 deletions ...Net/IotaWalletNet.Application/AccountContext/Queries/GetOutputs/GetOutputsQueryHandler.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,24 @@
using IotaWalletNet.Domain.PlatformInvoke;
using MediatR;
using Newtonsoft.Json;

namespace IotaWalletNet.Application.AccountContext.Queries.GetOutputs
{
public class GetOutputsQueryHandler : IRequestHandler<GetOutputsQuery, GetOutputsResponse>
{
public async Task<GetOutputsResponse> Handle(GetOutputsQuery request, CancellationToken cancellationToken)
{
GetOutputsQueryMessageData messageData = new GetOutputsQueryMessageData(request.FilterOptions);
GetOutputsQueryMessage message = new GetOutputsQueryMessage(request.Username, messageData);

string json = JsonConvert.SerializeObject(message);
RustBridgeGenericResponse genericResponse = await request.Account.SendMessageAsync(json);

GetOutputsResponse response = genericResponse.IsSuccess
? genericResponse.As<GetOutputsResponse>()!
: new GetOutputsResponse() { Error = genericResponse.As<RustBridgeResponseError>(), Type = "error" };

return response;
}
}
}
15 changes: 15 additions & 0 deletions ...Net/IotaWalletNet.Application/AccountContext/Queries/GetOutputs/GetOutputsQueryMessage.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,15 @@
using IotaWalletNet.Domain.Common.Models;

namespace IotaWalletNet.Application.AccountContext.Queries.GetOutputs
{
public class GetOutputsQueryMessage : AccountMessage<GetOutputsQueryMessageData>
{
private const string METHOD_NAME = "outputs";

public GetOutputsQueryMessage(string username, GetOutputsQueryMessageData getOutputsQueryMessageData)
:base(username, METHOD_NAME, getOutputsQueryMessageData)
{

}
}
}
14 changes: 14 additions & 0 deletions ...IotaWalletNet.Application/AccountContext/Queries/GetOutputs/GetOutputsQueryMessageData.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,14 @@
using IotaWalletNet.Domain.Common.Models.Output;

namespace IotaWalletNet.Application.AccountContext.Queries.GetOutputs
{
public class GetOutputsQueryMessageData
{
public OutputFilterOptions FilterOptions { get; set; }

public GetOutputsQueryMessageData(OutputFilterOptions filterOptions)
{
FilterOptions = filterOptions;
}
}
}
10 changes: 10 additions & 0 deletions ...lletNet/IotaWalletNet.Application/AccountContext/Queries/GetOutputs/GetOutputsResponse.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,10 @@
using IotaWalletNet.Domain.Common.Models.Output;
using IotaWalletNet.Domain.PlatformInvoke;

namespace IotaWalletNet.Application.AccountContext.Queries.GetOutputs
{
public class GetOutputsResponse : RustBridgeResponseBase<List<OutputData>>
{

}
}
3 changes: 3 additions & 0 deletions csharp/IotaWalletNet/IotaWalletNet.Application/Common/Interfaces/IAccount.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,10 +2,12 @@
using IotaWalletNet.Application.AccountContext.Commands.MintNfts;
using IotaWalletNet.Application.AccountContext.Queries.GetAddresses;
using IotaWalletNet.Application.AccountContext.Queries.GetBalance;
using IotaWalletNet.Application.AccountContext.Queries.GetOutputs;
using IotaWalletNet.Domain.Common.Interfaces;
using IotaWalletNet.Domain.Common.Models.Address;
using IotaWalletNet.Domain.Common.Models.Network;
using IotaWalletNet.Domain.Common.Models.Nft;
using IotaWalletNet.Domain.Common.Models.Output;
using static IotaWalletNet.Application.AccountContext.Commands.SyncAccount.SyncAccountCommandHandler;

namespace IotaWalletNet.Application.Common.Interfaces
Expand All @@ -25,5 +27,6 @@ public interface IAccount : IRustBridgeCommunicator
Task<GenerateAddressesResponse> GenerateAddressesAsync(uint numberOfAddresses = 1, NetworkType networkType = default);
Task<MintNftsResponse> MintNftsAsync(List<NftOptions> nftsOptions);
Task<GetAddressesResponse> GetAddresses();
Task<GetOutputsResponse> GetOutputs(OutputFilterOptions? outputFilterOptions = null);
}
}
15 changes: 15 additions & 0 deletions csharp/IotaWalletNet/IotaWalletNet.Domain/Common/Models/Output/OutputFilterOptions.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,15 @@
namespace IotaWalletNet.Domain.Common.Models.Output
{
public class OutputFilterOptions
{
/// <summary>
/// Filter all outputs where the booked milestone index is below the specified timestamp
/// </summary>
public uint LowerBoundBookedTimestamp { get; set; }

/// <summary>
/// Filter all outputs where the booked milestone index is above the specified timestamp
/// </summary>
public uint UpperBoundBookedTimestamp { get; set; }
}
}