|
|
Imports System.IO
|
|
|
Imports System.Net.Sockets
|
|
|
Imports Microsoft.VisualBasic.ComputingServices.TaskHost
|
|
|
Imports Microsoft.VisualBasic.Net
|
|
|
Imports Microsoft.VisualBasic.Serialization
|
|
|
Imports RQL.HttpInternal
|
|
|
|
|
|
''' <summary>
|
|
|
''' 在线查询服务提供模块
|
|
|
''' </summary>
|
|
|
Public Class RESTProvider : Inherits HttpInternal.HttpServer
|
|
|
|
|
|
Public ReadOnly Property Repository As Repository
|
|
|
Public ReadOnly Property LinqProvider As LinqPool = New LinqPool
|
|
|
|
|
|
''' <summary>
|
|
|
'''
|
|
|
''' </summary>
|
|
|
''' <param name="portal"></param>
|
|
|
''' <param name="repo">需要在这里将url转换为Long以进行protocol的绑定操作</param>
|
|
|
Sub New(portal As Integer, repo As Repository)
|
|
|
Call MyBase.New(portal)
|
|
|
Me.Repository = repo
|
|
|
End Sub
|
|
|
|
|
|
''' <summary>
|
|
|
''' http://linq.gcmodeller.org/kegg/pathways?where=test_expr(pathway)
|
|
|
''' 测试条件里面的对象实例的标识符使用资源url里面的最后一个标识符为变量名
|
|
|
''' 测试条件表达式使用VisualBasic的语法
|
|
|
''' 测试条件必须以where起头开始
|
|
|
''' </summary>
|
|
|
''' <param name="p"></param>
|
|
|
''' <return>返回一个网络终点IpEndPoint</return>
|
|
|
Public Overrides Sub handleGETRequest(p As HttpProcessor)
|
|
|
Dim url As String = p.http_url
|
|
|
Dim pos As Integer = InStr(url, "?")
|
|
|
Dim expr As String = ""
|
|
|
If pos = 0 Then
|
|
|
' expr为空
|
|
|
Else
|
|
|
expr = Mid(url, pos + 1).Trim
|
|
|
End If
|
|
|
|
|
|
Dim source = Repository.GetRepository(url, expr) ' expr为空的话，则没有where测试，则返回所有数据
|
|
|
Dim linq As IPEndPoint = LinqProvider.OpenQuery(source, Repository.GetType(url))
|
|
|
Call p.outputStream.WriteLine(linq.GetJson)
|
|
|
End Sub
|
|
|
|
|
|
Public Overrides Sub handlePOSTRequest(p As HttpProcessor, inputData As StreamReader)
|
|
|
Call p.writeFailure("Method not allowed!")
|
|
|
End Sub
|
|
|
|
|
|
Protected Overrides Function __httpProcessor(client As TcpClient) As HttpProcessor
|
|
|
Return New HttpProcessor(client, Me)
|
|
|
End Function
|
|
|
End Class
|
