minudika

 package com.wso2.test;  
 import org.apache.synapse.MessageContext;  
 import org.apache.synapse.mediators.AbstractMediator;  
 import org.apache.synapse.registry.Registry;  
 import org.apache.synapse.config.Entry;  
 import org.apache.axiom.om.impl.llom.OMTextImpl;  

 public class RecourceFinder extends AbstractMediator { 
  
      String REGISTRY_MAPPING_STORAGE_URL = "conf:/repository/new";  

minudika

@Source(type = 'http-request', source.id='login-request', 
receiver.url="https://localhost:8280/analytics", 
@map(type='json', 
@attributes(messageId='trp:messageId', 
username='$.username', loginTime='$.loginTime', loginIp = '$.loginIp')))
define stream InputStream (
    messageId string,
    username string,
    loginIp string,
    loginTime long);

minudika

@Source(type = 'http-request', source.id='login-request', 
receiver.url="https://localhost:8280/analytics", 
@map(type='json', 
@attributes(messageId='trp:messageId', 
username='$.username', loginTime='$.loginTime', loginIp = '$.loginIp')))
define stream InputStream (
    messageId string,
    username string,
    loginIp string,
    loginTime long);

minudika

@sink(type='http-request', sink.id='production-alerts', 
publisher.url='http://localhost:8080/alerts',
@map(type='json'))
define stream ProductionAlertStream (id string, name string, amount double);

@source(type='http-response' , sink.id='production-alerts', http.status.code='200',
@map(type='json'))
define stream ResponseStream(alertId long, alertMessage string);

minudika

@sink(type='http',
publisher.url='http://localhost:8009/OutputStream', method='{{method}}',
headers="'content-type:application/xml','content-length:94'",
@map(type='xml')))
define stream OutputStream (id String, volume double, price float, method string);

minudika

@Source(type = 'http', 
receiver.url="https://localhost:8280/Analytics/InputStream", worker.count='10',
@map(type='json')
define stream InputStream (id string, price float, volume double);

minudika

// Specify the Siddhi application name.
var siddhiApplication = 'LoginRiskCalculator';
// Specify the Siddhi input stream name.
var siddhiInputStream = 'InputStream';

function onLoginRequest(context) {
    executeStep(1, {
        onSuccess: function (context) {
            getRiskOfLoginAttempt(context);
        }

minudika

@App:name("AbnormalLoginBehaviour")

-- Please refer to https://docs.wso2.com/display/SP400/Quick+Start+Guide on getting started with SP editor. 

@sink(type = 'log', @map(type = 'text'))
@Source(type = 'http-request', source.id='testsource', 
receiver.url="https://localhost:8280/Analytics/InputStream", 
@map(type='json', @attributes(messageId='trp:messageId', username='$.event.username', loginTime='$.event.loginTime', loginIp = '$.event.loginIp')))
define stream InputStream (
    messageId string,

minudika

@Source(type = 'http-request', source.id='testsource', receiver.url="https://localhost:8280/Analytics/InputStream", 
@map(type='json', 
@attributes(messageId='trp:messageId', 
username='$.event.username', 
loginTime='$.event.loginTime', 
loginIp = '$.event.loginIp')))
define stream InputStream (messageId string, username string, loginIp string, loginTime long);

minudika

@sink(type='http-response', source.id='testsource', message.id='{{messageId}}', 
@map(type='json'))
define stream OutputStream (messageId string, username string,risk double);