The goal of the system is to serve offers to users. Using the Ports and Adaptors pattern to illustrate how a service can be easily developed and tested in isolation before being deployed as microservices.
The project is a POC that supporting the concepts outlined in the associated BLOG post.
- Return offers filtered by credit score.
- Return user with eligible offers based on the following rules:
- (a) The user's credit score is within the offer's range
- (b) The user's current outstanding loan is less than or equal to the auto loan offer's high limit (maximumAmount).
- Design the eligibility system to be easily extended with new rules.
- Deserialize the sample data in an asynchronous manor and service the appropriate offers from step
The json data used for validation is included in the data.json file in the fixtures folder. This data should be deserialized and processed by type.
Starting the Partner Service
sbt 'runMain krs.partner.service.PartnerServer -admin.port=:9990'Starting the User Service
sbt 'runMain krs.user.service.UserServer -admin.port=:9991'Starting the API Service
sbt 'runMain rest.APIServer -admin.port=:9992'Confirm the services are working with the REST services:
Getting offers by credit score
curl http://localhost:8080/offers/550Getting user with offers
curl http://localhost:8080/user/1Load Testing
brew install wrk
wrk -t12 -c400 -d30s http://127.0.0.1:8080/user/2System architecture:
Manages the description and auction status (created, auction, completed, cancelled) of an item.
- getItem - Gets an item by an ID.
- getItemsForUser - Gets a list of items in a provided status that are owned by a given user.
- AuctionStarted (public) - When the auction is started, in response to startAuction.
- ItemUpdated (private) - When user editable fields on an item are updated in response to createItem.
- AuctionCancelled (private) - When the auction is cancelled, in response to cancelAuction.
- AuctionFinished (private) - When the auction is finished, in response to BiddingFinished.
Event emitted publically are published via a broker topic named item-ItemEvent.
- createItem - Creates an item - emits ItemUpdated.
- updateItem - Updates user editable properties of an item, if allowed in the current state (eg, currency can't be updated after auction is started), emits ItemUpdated.
- startAuction - Starts the auction if current state allows it, emits AuctionStarted.
- cancelAuction (not supported) - Cancels the auction if current state allows it, emits AuctionCancelled.
- BidPlaced - Updates the current price of the item.
- BiddingFinished - Completes the auction if current state allows, emits AuctionFinished.
Manages bids on items.
- getBids - Gets all the bids for an item.
- BidPlaced - When a bid is placed, in response to placeBid.
- BiddingFinished - When bidding has finished, in response to finishBidding.
- placeBid - Places a bid, if the bid is greater than the current bid, emits BidPlaced.
- finishBidding - Triggered by scheduled task that polls a read side view of auctions to finish, emits BiddingFinished
- AuctionStarted - Creates a new auction for the item
- AuctionCancelled - Completes an auction prematurely
Handles all item searching.
- search - Search for items currently under auction matching a given criteria.
- getUserAuctions - Gets a list of all current auctions that a user is participating in by user ID.
- ItemUpdated - Creates or updates the details for an item in the search index
- AuctionStarted - Updates the status for an item to started
- AuctionFinished - Deletes an item from the search index
- AuctionCancelled - Deletes an item from the search index
- BidPlaced - Updates the current price for an item, if it exists in the index
Handles the transaction of negotiating delivery info and making payment of an item that has completed an auction.
- getTransaction - Gets a transaction by an items ID.
- getTransactionsForUser - Gets a list of all transactions that a given user is involved with.
- DeliveryByNegotiation - When the buyer has selected by negotiation, in response to submitDeliveryDetails.
- DeliveryPriceUpdated - When the seller has updated the delivery price, in response to setDeliveryPrice.
- PaymentDetailsSubmitted - When payment details are submitted, in response to submitPaymentDetails.
- PaymentConfirmed - When payment has been confirmed, in response to payment service ReceivedPayment.
- PaymentFailed - When payment has failed, in response to payment service FailedPayment.
- ItemDispatched - When the item has been dispatched, in response to dispatchItem.
- ItemReceived - When the item has been received, in response to receiveItem.
- MessageSent - When a user has sent a message, in response to sendMessage.
- RefundInitiated - When the seller has initiated a refund, in response to initiateRefund.
- RefundConfirmed - When a refund has been confirmed.
- sendMessage - Send a message to the other user, emits MessageSent.
- submitDeliveryDetails - Used by the buyer to submit delivery details, emits DeliveryDetailsSubmitted.
- setDeliveryPrice - Used by the seller to set the delivery price when delivery option is by negotiation, emits DeliveryPriceUpdated.
- submitPaymentDetails - Used by the buyer to submit payment details.
- dispatchItem - Used by the seller to say they have dispatched the item.
- receiveItem - Used by the buyer to say they have received the item.
- initiateRefund - Used by the seller to initiate a refund.
- AuctionFinished - Creates the transaction.
- ReceivedPayment - Indicates the payment has been made, emits PaymentConfirmed.
- FailedPayment - Indicates payment failed, emits PaymentFailed.
- MadeRefund - Indicates a refund was made, emits RefundConfirmed.