import { common, abilityAccessCtrl } from '@kit.AbilityKit';
import { BusinessError } from '@kit.BasicServicesKit';

let atManager = abilityAccessCtrl.createAtManager();

try {
  // 以动态弹窗的方式向用户申请授权
  atManager.requestPermissionsFromUser(context, ['ohos.permission.DISTRIBUTED_DATASYNC'])
    .then((result) => {
      console.info(`request permission result: ${JSON.stringify(result)}`);
    }).catch((err: BusinessError) => {
      console.error(`Failed to request permissions from user. Code: ${err.code}, message: ${err.message}`);
    });
} catch (error) {
  let err: BusinessError = error as BusinessError;
  console.error(`Catch err. Failed to request permissions from user. Code: ${err.code}, message: ${err.message}`);
}

import { fileIo as fs } from '@kit.CoreFileKit';
import { common } from '@kit.AbilityKit';
import { BusinessError } from '@kit.BasicServicesKit';
import { fileUri } from '@kit.CoreFileKit';

let pathDir: string = context.filesDir;
let distributedPathDir: string = context.distributedFilesDir;

// 待拷贝文件沙箱路径
let filePath: string = pathDir + '/src.txt';

try {
  // 准备待拷贝沙箱文件
  let file = fs.openSync(filePath, fs.OpenMode.CREATE | fs.OpenMode.READ_WRITE);
  fs.writeSync(file.fd, 'Create file success');
  fs.closeSync(file);
} catch (error) {
  console.error(`Failed to createFile. Code: ${error.code}, message: ${error.message}`);
}

// 获取待拷贝源文件uri
let srcUri = fileUri.getUriFromPath(filePath);

// 获取目标路径(分布式目录)的uri
let destUri: string = fileUri.getUriFromPath(distributedPathDir + '/src.txt');

try {
  // 将沙箱路径下的源文件拷贝到目标分布式目录下
  fs.copy(srcUri, destUri).then(() => {
    console.info(`Succeeded in copying---. `);
    console.info(`src: ${srcUri} dest: ${destUri}`);
  }).catch((error: BusinessError) => {
    let err: BusinessError = error as BusinessError;
    console.error(`Failed to copy. Code: ${err.code}, message: ${err.message}`);
  });
} catch (error) {
  console.error(`Catch err. Failed to copy. Code: ${error.code}, message: ${error.message}`);
}

import { fileIo as fs } from '@kit.CoreFileKit';
import { common } from '@kit.AbilityKit';
import { BusinessError } from '@kit.BasicServicesKit';
import { fileUri } from '@kit.CoreFileKit';
import { distributedDeviceManager } from '@kit.DistributedServiceKit';

// ...
let pathDir: string = context.filesDir;
let distributedPathDir: string = context.distributedFilesDir;

// 待拷贝文件的目标路径(沙箱路径)
let destPath: string = pathDir + '/dest.txt';

// 获取目标路径uri
let destUri = fileUri.getUriFromPath(destPath);

// 拷贝源文件路径(分布式目录)
let srcPath = distributedPathDir + '/src.txt';

// 获取源路径uri
let srcUri: string = fileUri.getUriFromPath(srcPath);

// 定义拷贝回调
let progressListener: fs.ProgressListener = (progress: fs.Progress) => {
  console.info(`progressSize: ${progress.processedSize}, totalSize: ${progress.totalSize}`);
};

let options: fs.CopyOptions = {
  'progressListener': progressListener
};

// 通过分布式设备管理的接口获取设备A的networkId信息
let dmInstance = distributedDeviceManager.createDeviceManager('com.example.hap');
let deviceInfoList: distributedDeviceManager.DeviceBasicInfo[] = dmInstance.getAvailableDeviceListSync();

if (deviceInfoList && deviceInfoList.length > 0) {
  console.info(`success to get available device list`);
  // 这里只是两个设备连接，列表中首个即为A设备的networkId
  let networkId = deviceInfoList[0].networkId;
  
  // 定义访问分布式目录的回调
  let listeners: fs.DfsListeners = {
    onStatus: (networkId: string, status: number): void => {
      console.error(`Failed to access public directory，${status}`);
    }
  };
  
  // 开始跨设备文件拷贝
  fs.connectDfs(networkId, listeners).then(() => {
    try {
      // 将分布式目录下的文件拷贝到其他沙箱路径下
      fs.copy(srcUri, destUri, options).then(() => {
        console.info(`Succeeded in copying from distribted path`);
        console.info(`src: ${srcUri} dest: ${destUri}`);
        // 拷贝完成后清理分布式目录下的临时文件
        fs.unlinkSync(srcPath);
      }).catch((error: BusinessError) => {
        let err: BusinessError = error as BusinessError;
        console.error(`Failed to copy. Code: ${err.code}, message: ${err.message}`);
      });
    } catch (error) {
      console.error(`Catch err. Failed to copy. Code: ${error.code}, message: ${error.message}`);
    }
  }).catch((error: BusinessError) => {
    let err: BusinessError = error as BusinessError;
    console.error(`Failed to connect dfs. Code: ${err.code}, message: ${err.message}`);
  });
}

import { BusinessError } from '@kit.BasicServicesKit';
import { distributedDeviceManager } from '@kit.DistributedServiceKit';
import { fileIo as fs } from '@kit.CoreFileKit';

// 获取设备A的networkId
// ...
let dmInstance = distributedDeviceManager.createDeviceManager('com.example.hap');
let deviceInfoList: distributedDeviceManager.DeviceBasicInfo[] = dmInstance.getAvailableDeviceListSync();

if (deviceInfoList && deviceInfoList.length > 0) {
  console.info(`Success to get available device list`);
  let networkId = deviceInfoList[0].networkId;
  
  // 关闭跨设备文件访问
  fs.disconnectDfs(networkId).then(() => {
    console.info(`Success to disconnect dfs`);
  }).catch((err: BusinessError) => {
    console.error(`Failed to disconnect dfs. Code: ${err.code}, message: ${err.message}`);
  });
}