SmbNamedPipe pipe = new SmbNamedPipe(url, SmbPipeResource.PIPE_TYPE_RDWR, ctx());

            // Assert: type is named pipe and pipe type preserved
            assertEquals(SmbConstants.TYPE_NAMED_PIPE, pipe.getType(), "Type should be TYPE_NAMED_PIPE");
            assertEquals(SmbPipeResource.PIPE_TYPE_RDWR, pipe.getPipeType(), "Pipe type should match constructor");
        }

        @ParameterizedTest

        assertEquals(SmbFile.TYPE_PRINTER, printerShare.getType());

        // Test for TYPE_NAMED_PIPE
        SmbShareInfo pipeShare = new SmbShareInfo("PIPE", 3, "A named pipe");
        assertEquals(SmbFile.TYPE_NAMED_PIPE, pipeShare.getType());

        // Test for TYPE_SHARE (disk share)
        SmbShareInfo diskShare = new SmbShareInfo("DISK", 0, "A disk share");

     */
    public SmbNamedPipe(final String url, final int pipeType) throws MalformedURLException, UnknownHostException {
        super(url);
        this.pipeType = pipeType;
        type = TYPE_NAMED_PIPE;
    }

    /**
     * Constructs an SmbNamedPipe for a specified pipe on an SMB server.
     *
     * @param url the SMB URL of the named pipe
     * @param pipeType the type of the pipe

        this.access = access;
        this.sharing = sharing;

        try (SmbTreeHandleInternal th = file.ensureTreeConnected()) {
            this.smb2 = th.isSMB2();
            if (file.getType() != SmbConstants.TYPE_NAMED_PIPE) {
                try (SmbFileHandle h = ensureOpen()) {}
                this.openFlags &= ~(SmbConstants.O_CREAT | SmbConstants.O_TRUNC);
            }

            init(th);

                if (file.type == SmbFile.TYPE_NAMED_PIPE) {
                    request.minCount = request.maxCount = request.remaining = 1024;
                }
                file.send(request, response);
            } catch (final SmbException se) {
                if (file.type == SmbFile.TYPE_NAMED_PIPE && se.getNtStatus() == NtStatus.NT_STATUS_PIPE_BROKEN) {
                    return -1;

    }

    @ParameterizedTest
    @DisplayName("Test getType with different share types")
    @CsvSource({ "1, " + SmbConstants.TYPE_PRINTER, // Printer share
            "3, " + SmbConstants.TYPE_NAMED_PIPE, // Named pipe
            "0, " + SmbConstants.TYPE_SHARE, // Standard share
            "2, " + SmbConstants.TYPE_SHARE, // Unknown type defaults to share

        void namedPipeBrokenPipeReturnsMinusOne() throws Exception {
            when(mockTree.isSMB2()).thenReturn(false);
            when(mockFile.getType()).thenReturn(SmbConstants.TYPE_NAMED_PIPE);

            // th.send(request, response, ...) throws SmbException with NT_STATUS_PIPE_BROKEN
            doThrow(new SmbException(NtStatus.NT_STATUS_PIPE_BROKEN, false)).when(mockTree)

        printerShare.netname = "PrinterShare";
        printerShare.type = 1;
        printerShare.remark = "Printer share";

        // Type 3 (named pipe) -> TYPE_NAMED_PIPE (16)
        srvsvc.ShareInfo1 pipeShare = new srvsvc.ShareInfo1();
        pipeShare.netname = "PipeShare";
        pipeShare.type = 3;
        pipeShare.remark = "Named pipe";

        setNonPooled(unshared);
        if (!getLocator().isIPC()) {
            throw new MalformedURLException("Named pipes are only valid on IPC$");
        }
        this.fileLocator.updateType(TYPE_NAMED_PIPE);
    }

    /**
     * Open the Named Pipe resource specified by the url
     * parameter. The pipeType parameter should be at least one of
     * the <code>PIPE_TYPE</code> flags combined with the bitwise OR

        assertEquals(0x02, SmbConstants.TYPE_WORKGROUP);
        assertEquals(0x04, SmbConstants.TYPE_SERVER);
        assertEquals(0x08, SmbConstants.TYPE_SHARE);
        assertEquals(0x10, SmbConstants.TYPE_NAMED_PIPE);
        assertEquals(0x20, SmbConstants.TYPE_PRINTER);
        assertEquals(0x40, SmbConstants.TYPE_COMM);
    }

    @Test
    @DisplayName("Should define open flags constants")