pbni-rs 0.1.2

PBNI for Rust
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105

use crate::{bindings::*, session::OwnedSession, *};
use libloading::Library;
use std::{borrow::Cow, ffi::OsStr};

/// 虚拟机对象
///
/// # Examples
/// ```
/// let vm = VM::new(r#"C:\Program Files (x86)\Appeon\Shared\PowerBuilder\PBVM190.DLL"#).unwrap();
/// let session = vm.new_session("pbrs", &[r#"pbrs\pbw\pbrs.pbl"#]).unwrap();
/// ```
pub struct VM {
    ptr: pbvm,
    lib: Library
}

impl VM {
    /// 从指定`PBVM`dll路径加载虚拟机对象
    pub fn new(file_name: impl AsRef<OsStr>) -> Result<VM> {
        unsafe {
            let lib = Library::new(file_name).map_err(|_| PBXRESULT::E_GET_PBVM_FAILED)?;
            let fn_get_vm = lib
                .get::<fn(*mut Option<pbvm>) -> PBXRESULT>(b"PB_GetVM\0")
                .map_err(|_| PBXRESULT::E_GET_PBVM_FAILED)?;
            let mut pvm = None;
            let pbxr = fn_get_vm(&mut pvm);
            if pbxr.is_err() {
                return Err(pbxr);
            }
            if pvm.is_none() {
                return Err(PBXRESULT::E_GET_PBVM_FAILED);
            }
            Ok(VM {
                ptr: pvm.unwrap(),
                lib
            })
        }
    }

    /// 新建Session对象
    pub fn new_session<'a>(
        &'a self,
        applicationName: impl AsPBStr,
        libraryList: &[impl AsPBStr]
    ) -> Result<OwnedSession<'a>> {
        if libraryList.is_empty() {
            return Err(PBXRESULT::E_INVALID_ARGUMENT);
        }
        let applicationName = applicationName.as_pbstr();
        if applicationName.is_empty() {
            return Err(PBXRESULT::E_INVALID_ARGUMENT);
        }
        unsafe {
            let libraryList: Vec<Cow<'_, PBStr>> = libraryList.iter().map(|item| item.as_pbstr()).collect();
            let libraryList: Vec<LPCTSTR> = libraryList.iter().map(|item| item.as_ptr()).collect();
            let mut session = NonNull::dangling();
            let pbxr = ffi::pbvm_CreateSession(
                self.ptr,
                applicationName.as_ptr(),
                libraryList.as_ptr(),
                libraryList.len() as pbuint,
                &mut session
            );
            if pbxr.is_ok() {
                Ok(OwnedSession::from_ptr(session))
            } else {
                Err(pbxr)
            }
        }
    }

    /// 运行PB工程
    pub fn run_application<'a>(
        &'a self,
        applicationName: impl AsPBStr,
        libraryList: &[impl AsPBStr],
        commandLine: impl AsPBStr
    ) -> Result<OwnedSession<'a>> {
        if libraryList.is_empty() {
            return Err(PBXRESULT::E_INVALID_ARGUMENT);
        }
        let applicationName = applicationName.as_pbstr();
        if applicationName.is_empty() {
            return Err(PBXRESULT::E_INVALID_ARGUMENT);
        }
        unsafe {
            let libraryList: Vec<Cow<'_, PBStr>> = libraryList.iter().map(|item| item.as_pbstr()).collect();
            let libraryList: Vec<LPCTSTR> = libraryList.iter().map(|item| item.as_ptr()).collect();
            let mut session = NonNull::dangling();
            let pbxr = ffi::pbvm_RunApplication(
                self.ptr,
                applicationName.as_ptr(),
                libraryList.as_ptr(),
                libraryList.len() as pbuint,
                commandLine.as_pbstr().as_ptr(),
                &mut session
            );
            if pbxr.is_ok() {
                Ok(OwnedSession::from_ptr(session))
            } else {
                Err(pbxr)
            }
        }
    }
}