};

        eventSource.addEventListener('phase', function(e) {
            var data = JSON.parse(e.data);
            if (data.phase) {
                if (data.status === 'start') {
                    updatePhase(data.phase, 'active');
                    var phaseMessage = config.labels.phases[data.phase] || data.message || 'Processing...';
                    // Replace __keywords__ placeholder with actual keywords

        int requestedState = Smb2LeaseState.SMB2_LEASE_FULL;
        int grantedState = Smb2LeaseState.SMB2_LEASE_READ_WRITE;

        Smb2LeaseKey key = leaseManager.requestLease(path, requestedState);
        leaseManager.updateLease(key, grantedState);

        LeaseEntry entry = leaseManager.getLease(key);
        assertEquals(grantedState, entry.getLeaseState());
    }

    @Test
    @DisplayName("Should handle lease break")

            );
        });

        // we also create the updateShas helper task that is associated with dependencyLicenses
        project.getTasks().register("updateShas", UpdateShasTask.class, t -> t.setParentTask(dependencyLicenses));
        return dependencyLicenses;
    }

        setDescription("Updates the sha files for the dependencyLicenses check");
        setOnlyIf(element -> parentTask.get().getLicensesDir() != null);
    }

    @TaskAction
    public void updateShas() throws NoSuchAlgorithmException, IOException {
        Set<File> shaFiles = parentTask.get().getShaFiles();

        for (File dependency : parentTask.get().getDependencies()) {

 *     dependencies = getProject().configurations.compile
 *   }
 * </pre>
 * <p>
 * Every jar must have a {@code .sha1} file in the licenses dir. These can be managed
 * automatically using the {@code updateShas} helper task that is created along
 * with this task. It will add {@code .sha1} files for new jars that are in dependencies
 * and remove old {@code .sha1} files that are no longer needed.
 * <p>

        }

        public byte[] getCurrentHash() {
            synchronized (hashLock) {
                return currentHash.clone();
            }
        }

        public void updateHash(byte[] newHash) {
            synchronized (hashLock) {
                if (newHash != null && newHash.length == currentHash.length) {
                    this.currentHash = newHash.clone();
                }
            }

            pathToLease.put(path, newKey);
            
            return newKey;
        } finally {
            lock.writeLock().unlock();
        }
    }
    
    public void updateLease(Smb2LeaseKey key, int grantedState) {
        LeaseEntry entry = leases.get(key);
        if (entry != null) {
            entry.updateState(grantedState);
        }
    }