 /*************************************************************/
 /* Copyright (c) 2010-2012 by Progress Software Corporation  */
 /*                                                           */
 /* All rights reserved.  No part of this program or document */
 /* may be  reproduced in  any form  or by  any means without */
 /* permission in writing from Progress Software Corporation. */
 /*************************************************************/
 /*------------------------------------------------------------------------
    File        : UserData 
    Purpose     : 
    Syntax      : 
    Description : 
    Author(s)   : hdaniels
    Created     :  
    Notes       : 
  ----------------------------------------------------------------------*/
 
routine-level on error undo, throw.

using Progress.Lang.* from propath.
using OpenEdge.DataAdmin.DataAccess.IDataAccess from propath.
using OpenEdge.DataAdmin.DataAccess.DataAccess from propath.


using OpenEdge.DataAdmin.DataSource.IDataSource from propath.
using OpenEdge.DataAdmin.DataSource.UserDataSource from propath.
using OpenEdge.DataAdmin.DataSource.TenantDataSource from propath.
using OpenEdge.DataAdmin.DataSource.DomainDataSource from propath.
 
using OpenEdge.DataAdmin.DataSource.UserTablePermissionDataSource from propath.
using OpenEdge.DataAdmin.DataSource.UserFieldPermissionDataSource from propath.
 
using OpenEdge.DataAdmin.DataSource.UserPermissionDataSource from propath.
using OpenEdge.DataAdmin.Message.IFetchRequest from propath.
using OpenEdge.DataAdmin.Message.ISaveRequest from propath.
using OpenEdge.DataAdmin.Message.ITableRequest from propath.

using OpenEdge.DataAdmin.DataAccess.DataAccessError from propath.

class OpenEdge.DataAdmin.DataAccess.UserData inherits DataAccess implements IDataAccess : 
 .
    define private variable mStart as integer no-undo.
    define private variable mSingle as logical no-undo.
    
    define public property BaseQuery as character no-undo
        get.     
        set.
    
    method public override void FetchData(msg as IFetchRequest):
        Url = msg:url.
        DatasetHandle = msg:DataHandle.       
        FillData(msg).
    end method.
    
    method public void FillData(msg as IFetchRequest):
        define variable hBuffer as handle no-undo.
        define variable userDataSource as UserDataSource no-undo.
        define variable tableRequest as ITableRequest no-undo.     
        define variable hTenant as handle no-undo.
        define variable hDomain as handle no-undo.
        define variable tntSource as TenantDataSource no-undo. 
        define variable dmnSource as DomainDataSource no-undo.
        define variable cJoinTables as character no-undo. 
        define variable cJoinPhysicalTables as character no-undo. 
        define variable cJoinQueries as character no-undo. 
        define variable cBaseQuery   as character no-undo. 
        define variable cQMode as character no-undo.
        define variable lJoin as logical no-undo.
        case msg:EntityName:
            when "User" then
            do:
                hBuffer = msg:DataHandle:get-buffer-handle ("ttUser").
                if valid-handle(hBuffer) then
                do:
                    hTenant = msg:DataHandle:get-buffer-handle ("ttTenant").
                    if valid-handle(hTenant) then
                    do:
                        tntSource = new TenantDataSource().
                        tntSource:FillMode = "Replace".
                        /* the user source will query on the tenant  */
                        tntSource:Prepare(hTenant,"","").
                        assign
                            cJoinTables = tntSource:tables
                            cJoinPhysicalTables = tntSource:PhysicalTables
                            cJoinQueries = trim(tntSource:BaseQuery) 
                            /* remove for or preselect */
                            cQmode = entry(1,cJoinQueries," ")      
                            cJoinQueries = left-trim(substr(cJoinQueries,length(cQmode) + 1))
                            lJoin = true. 
                            
                    end.
                    hDomain = msg:DataHandle:get-buffer-handle ("ttDomain").
                    if valid-handle(hDomain) then
                    do:
                        dmnSource = new DomainDataSource().
                        dmnSource:FillMode = "Replace".
                        /* the user source will query on the domain  */
                        dmnSource:Prepare(hDomain,"","").
                        
                        assign
                            cJoinTables = (if lJoin then cJoinTables + "," else "") 
                                          + entry(1,dmnSource:tables)
                            cJoinPhysicalTables = (if lJoin then cJoinPhysicalTables + "," else "") 
                                                   + entry(1,dmnSource:PhysicalTables)
                            cBaseQuery = trim(dmnSource:BaseQuery) 
                            /* remove for or preselect */
                            cQmode = entry(1,cBaseQuery," ")      
                            cJoinQueries = (if lJoin then cJoinQueries + ", " else "") 
                                         +  left-trim(entry(1,(substr(cBaseQuery,length(cQmode) + 1)))). 
                            lJoin = true.
                    end.
                    if lJoin then 
                        userDataSource = new UserDataSource(cJoinTables,cJoinPhysicalTables, cJoinQueries).    
                    else                 
                        userDataSource = new UserDataSource( ).    
                    userDataSource:FillMode = "Replace".
                    userDataSource:Url = Url.
                    tableRequest = msg:GetTableRequest("ttUser").
                    if valid-object(tableRequest) then 
                        userDataSource:Prepare(hBuffer,tableRequest).         
                    else
                        userDataSource:Prepare(hBuffer).                     
                end.     
                msg:DataHandle:Fill().
                if valid-object(userDataSource) and userDataSource:NumRecords <> ? then 
                    msg:SetTableTotal("ttUser",userDataSource:NumRecords).
            end.
            when "UserPermission" then
            do:
                FillPermisssion(msg).
            end.
        end case.
        finally: /* is not garbage collected if set-callback is used */       
            delete object userDatasource no-error.	
            delete object dmnSource no-error.
            delete object tntSource no-error.	
        end finally.               
    end method.    
    
    method private void  FillPermisssion(msg as IFetchRequest):
        define variable hUserPermission as handle no-undo.
        define variable hUserFieldPermission as handle no-undo.
        define variable hUserTablePermission as handle no-undo.
        define variable userPerm as UserPermissionDataSource no-undo.
        define variable userfieldPerm as IDataSource no-undo.
        define variable hFieldRel as handle no-undo.
        define variable usertablePerm as IDataSource no-undo.
        define variable hTableRel as handle no-undo.
        
        hUserPermission = msg:DataHandle:get-buffer-handle ("ttUserPermission").
        userPerm = new UserPermissionDataSource().
        PrepareDataSource(userPerm,hUserPermission,msg:GetTableQuery("ttUserPermission"),"Append").
        
        hUserTablePermission = msg:DataHandle:get-buffer-handle ("ttUserTablePermission").
        if valid-handle(hUserTablePermission) then
        do:
            hUserTablePermission:fill-mode = "no-fill".
        end.
        hUserFieldPermission = msg:DataHandle:get-buffer-handle ("ttUserFieldPermission").
        if valid-handle(hUserFieldPermission) then
        do:
            hUserFieldPermission:fill-mode = "no-fill".
        end.
       
        msg:DataHandle:Fill().
        hUserPermission:fill-mode = "no-fill".
        
        if not hUserPermission:table-handle:has-records 
        and userPerm:ExternalIDValue > "" then 
        do transaction:
            hUserPermission:buffer-create().
            hUserPermission::Id = userPerm:ExternalIDValue.  
        end.
        
        if valid-handle(hUserTablePermission) then
        do:
            usertablePerm = new UserTablePermissionDataSource(hUserPermission).
            hTablerel = hUserTablePermission:parent-relation.
            hTablerel:active = false.   
            PrepareDataSource(usertablePerm,hUserTablePermission,"","Append").
        end.
      
        if valid-handle(hUserFieldPermission) then
        do:
             userFieldPerm = new UserFieldPermissionDataSource(hUserPermission).
             hFieldRel = hUserFieldPermission:parent-relation.
             hFieldRel:active = false.
             PrepareDataSource(userFieldPerm,hUserFieldPermission,"","Append").
        end.
       
        msg:DataHandle:Fill().
      
        if valid-handle(hUserTablePermission) then
            hUserTablePermission:detach-data-source ().
        if valid-handle(hUserFieldPermission) then
            hUserFieldPermission:detach-data-source ().
        if valid-handle(hTablerel) then
              hTablerel:active = true.       
        if valid-handle(hFieldRel) then
             hFieldRel:active = true.       
        
        finally: /* are not garbage collected if set-callback is used*/
            delete object usertablePerm no-error. 		
            delete object userFieldPerm no-error.       
            delete object userPerm no-error.       
        end finally.
    end method.    
     
    /* This is the call back for the QueryString parsing. There is currently no mapping, but we override it in 
       order to return the ttPartition's parent keys to the Query. This allows us to extract the expression later.
       Because it is added as parent (i.e _tenant) we can also extract the actual query fields without these.        
    */
    method public override character ColumnSource (pcColumn as char):
        if pcColumn = "ttUser.TenantName" then 
        do:
            return "_tenant._tenant-name".    
        end.
        return super:ColumnSource(pccolumn).     
   
    end method.     

    method protected override character FindTableJoinValues(pTable as char,pFind as char):
        case pTable:
            when "_tenant" then
                return FindTenantJoin(pFind).
            
        end case.
        return ?.
    end method.

    method private character FindTenantJoin(pFind as char):
        buffer dictdb._tenant:find-unique(pFind).
        return "_User._Tenantid = " + quoter(_Tenant._Tenantid).
    end method.	 
    
	 
	method protected logical PrepareDataSource(ds as IDataSource,phbuffer as handle,pcQuery as char,pcMode as char):      
        ds:FillMode = pcMode.
        ds:Url = Url.
        return ds:Prepare(phBuffer,pcQuery,"").
    end method.     
    	
	method public override ISaveRequest SaveData(pChanges as ISaveRequest): 
        define variable hUser   as handle no-undo. 
        define variable userDataSource as UserDataSource no-undo.
        
        do transaction on error undo, throw:
             
            hUser = pChanges:DataHandle:get-buffer-handle ("ttUser") no-error.
            if valid-handle(hUser) then
            do:     
                userDataSource = new UserDataSource().
                userDataSource:Url = pChanges:Url.
                userDataSource:Save(hUser).
            end.
        end.
     
        return pChanges.
    end method.   
 
end class.
